我查看了project.json的ASP.Net 5团队wiki条目,以确定哪些脚本命令可用,目前列出了以下内容:
{
"scripts": {
"prebuild": "echo before building",
"postbuild": "echo after building",
"prepack": "echo before packing",
"postpack": "echo after packing",
"prerestore": "echo before restoring packages",
"postrestore": "echo after restoring packages"
}
}
这些都很简单易懂; 但是在Visual Studio中,只有prerestore和postrestore事件似乎真的开始了.预建和后期建设没有.
默认(beta 6) Visual Studio 2015模板添加以下脚本命令,该不在官方列表中:
"scripts": {
"prepublish": [ "npm install", "bower install", "gulp clean", "gulp min" ]
}
此外,似乎还有其他未记录的命令,我从同事创建的示例项目中继承了这些命令:
"scripts": {
"first-run": "npm install -g gulp bower && npm run update",
"prepare": [ …目的:
我正在使用StackExchange Redis Client.我的目标是从客户端公开的Pub Sub Subscriber创建一个Observable流,然后可以支持Observables的1-n订阅,每个订阅都有自己的LINQ过滤器.(发布按计划运行,问题纯粹围绕特定频道上的事件流订阅.)
背景:
我使用Redis Pub Sub作为事件源CQRS应用程序的一部分.具体用例是将事件发布给多个订阅者,然后更新各种读取模型,发送电子邮件等.
这些订阅者中的每一个都需要过滤他们处理的事件类型,为此我希望使用Rx .Net(Reactive Extensions)和LINQ来提供事件流的过滤条件,以便有效地处理对事件的反应出于兴趣.使用这种方法消除了使用事件总线实现注册处理程序的需要,并允许我通过部署1-n微服务向系统添加新投影,每个微服务都有1-n Observables使用自己的特定过滤器订阅事件流.
我做了什么:
1)我创建了一个继承自ObservableBase的类,重写了SubscribeCore方法,该方法接收来自Observables的订阅请求,将它们存储在ConcurrentDictionary中,并且当每个Redis通知从通道到达时,循环通过已注册的Observable订阅者并调用它们的OnNext方法传递RedisValue.
2)我创建了一个Subject,它也接受来自Observables的订阅,并调用它们的OnNext方法.同样,对象的使用似乎被许多人所厌恶.
问题:
我尝试过的方法确实起作用(至少表面上看),具有不同的性能水平,但是feel like a hack,我并没有按照预期的方式使用Rx.
我看到许多评论认为应尽可能使用内置的Observable方法,例如Observable.FromEvent,但这似乎与StackExchange Redis客户端订阅API无关,至少对我来说是这样.
我也理解接收流并转发到多个观察者的首选方法是使用ConnectableObservable,它似乎是为我面临的场景设计的(每个微服务将在内部订阅1-n Observables).目前,我无法理解如何将ConnectableObservable连接到StackExchange Redis的通知,或者它是否提供了对Observable的真正好处.
更新:
尽管在我的场景中完成不是问题(Disposal很好),但错误处理很重要; 例如,隔离在一个订户中检测到的错误,以防止所有订阅终止.