首页 > TAG信息列表 > rx-net

c#-根据输入序列的元素将IObservable转换为另一个故障或完成的序列

我正在实现一个进程间消息传递系统,例如客户端可以从服务器请求某些数据.服务器需要能够以部分答复的形式发送回其答复,并且还需要能够通知客户以防万一发生异常. 目前,我正在通过3种消息类型执行此操作： class PartialResponse : ResponseMessage { ... } class ResponseError : R

c# – 如何将阻塞事件转换为Observable？

我正在学习.net Rx(Reactive Extensions)库并尝试创建一个从Console读取用户输入的正确Observable. 到目前为止,我来到这里： public static IObservable<string> ConsoleInputObservable() { return Observable.Create<string>(observer => {

c# – 如何获取IObservable的最后已知值？

假设我正在使用Rx.Net构建一个图像编辑器.用户可以使用鼠标操作画布.应用的操作取决于当前选定的工具.例如,可能存在“绘图”工具和“擦除”工具.一次只能选择一个工具. 我有三个流;一个用于鼠标事件;一个用于通过单击鼠标发出的命令;和另一个工具选择： IObservable<ITool> toolSel

c# – 使用AsObservable观察TPL数据流块而不消耗消息

我有一系列TPL Dataflow块,希望观察系统内部的某些进展. 我知道我可以将TransformBlock堵塞到我想要观察的网格中,让它发布到某种程度的进度更新程序,然后将消息保持不变到下一个块.我不喜欢这个解决方案,因为块的纯粹是因为它的副作用,我还必须在任何我想要观察的地方改变块链接逻