基于閱讀此問題:SubscribeOn和ObserveOn有什么區(qū)別ObserveOn設(shè)置Subscribe執(zhí)行處理程序中代碼的位置:stream.Subscribe(_ => { // this code here });該SubscribeOn方法設(shè)置在哪個線程上完成流的設(shè)置。我被領(lǐng)會到,如果未明確設(shè)置這些參數(shù),則使用TaskPool?,F(xiàn)在我的問題是,讓我說這樣的事情:Observable.Interval(new Timespan(0, 0, 1)).Where(t => predicate(t)).SelectMany(t => lots_of(t)).ObserveOnDispatcher().Subscribe(t => some_action(t));鑒于在分配器上執(zhí)行,Where predicate并且SelectMany lots_of在哪里some_action執(zhí)行?
3 回答

倚天杖
TA貢獻(xiàn)1828條經(jīng)驗 獲得超3個贊
我經(jīng)常會誤認(rèn)為.SubcribeOn
用來設(shè)置.Subscribe
執(zhí)行內(nèi)部代碼的線程。但是要記住,只是認(rèn)為發(fā)布和訂閱必須像陰陽配對。設(shè)置Subscribe's code
執(zhí)行位置ObserveOn
。設(shè)置Observable's code
執(zhí)行位置SubscribeOn
?;蛟诳偨Y(jié)口頭禪:where-what
,Subscribe-Observe
,Observe-Subscribe
。
- 3 回答
- 0 關(guān)注
- 1381 瀏覽
添加回答
舉報
0/150
提交
取消