解决方法
Rx合同要求通知是连续的,对于多个操作符来说是一个逻辑上的必要条件.也就是说,您可以使用可用的Synchronize方法来获取此行为.
var subject = new Subject<int>();
var syncedSubject = Subject.Synchronize(subject);
您现在可以对syncedSubject进行并发调用.
对于必须同步的观察者,您还可以使用：
var observer = Observer.Create<Unit>(...);
var syncedObserver = Observer.Synchronize(observer);
测试：
Func<int,Action> onNext = i => () => syncedSubject.OnNext(i);
Parallel.Invoke
(
onNext(1),onNext(2),onNext(3),onNext(4)
);
