RxJS有沒有類似下面的解決方案? Is it possible to invoke subscribers's OnNexts on different threads in Rx? P.S.我的第一個,幼稚的做法(在CoffeeScript中)顯然已經失敗: hObs = Rx.Observable.interval(35000)
.startWith(-1)
.selec
我有一個可觀察的集合,我想繼續餵養對象,並且即使在某人訂閱了它(哪一個課程是可觀察的主要目標)之後,它們也應該到達觀察者。我該怎麼做? 在下面的程序中,在訂閱發生之後,我想再輸入3個數字,這些數字應該到達觀察者。我該怎麼做呢? 我不想通過執行IObservable<int>並使用Publish方法來實現我自己的Observable類的路由嗎?有沒有其他方法可以實現這一點? public class