代码之家 › 专栏 › 技术社区 › SoftMemes

在反应式扩展(Rx)中,从不同线程触发OnNext是否粗鲁?

system.reactive concurrency multithreading .net

SoftMemes · 技术社区 · 14 年前

当您自己实现IObserver时,您知道如何处理OnNext从不同线程并发或顺序调用的情况,但是对于这种情况,内置的反应式扩展原语的期望是什么?例如,BufferWithTime能否处理从多个线程调用的OnNext?从多个线程并发调用?

1 回复 | 直到 14 年前

Jeffrey van Gogh 14 年前

只要您遵守Rx使用的合同的两部分,您就可以:

您可以使用Observable.Synchronize操作符来修复不遵循这两个规则的IObservable实现。

杰弗里

推荐文章

Nicolas · c#/中多个Rx受试者的依赖注入。净核心

7 年前

user584018 · 如何获取文件的增量内容

7 年前

SuperJMN · 如何计算LINQ管道要完成的ETA?

7 年前

Seishin Okigaru · RXSwift,检测到重入异常

7 年前

user584018 · 这段代码是否适用于使用Rx核心的UdpClient

7 年前

Umair · IObservable收集当前流中的所有元素并执行批量操作

7 年前

marsop · 在typescript中观察集合

7 年前

thk · Rxjs init resource once with hot observable

7 年前

Wouter · Rx TestScheduler不能很好地处理返回和延迟

7 年前

gakera · 如何使用反应式用户界面触发按钮点击与按钮按下(按住)后的不同操作

7 年前