2
當你自己實現IObserver時,你知道你將如何處理OnNext從不同線程中併發地或順序地被調用的情況,但是當涉及到這個時,內置Reactive Extension原語的期望是什麼?例如,將BufferWithTime應用於從多個線程調用的OnNext?從多個線程同時調用?從Reactive Extensions(Rx)中的不同線程觸發OnNext不禮貌嗎?
當你自己實現IObserver時,你知道你將如何處理OnNext從不同線程中併發地或順序地被調用的情況,但是當涉及到這個時,內置Reactive Extension原語的期望是什麼?例如,將BufferWithTime應用於從多個線程調用的OnNext?從多個線程同時調用?從Reactive Extensions(Rx)中的不同線程觸發OnNext不禮貌嗎?
只要你遵循的Rx使用合同兩個部分,你應該罰款:
可以使用Observable.Synchronize運營商來解決的IObservable的實現,不遵循這兩個規則。
Jeffrey