基于閱讀此問(wèn)題:SubscribeOn和ObserveOn有什么區(qū)別ObserveOn設(shè)置Subscribe執(zhí)行處理程序中代碼的位置:stream.Subscribe(_ => { // this code here });該SubscribeOn方法設(shè)置在哪個(gè)線程上完成流的設(shè)置。我被領(lǐng)會(huì)到,如果未明確設(shè)置這些參數(shù),則使用TaskPool。現(xiàn)在我的問(wèn)題是,讓我說(shuō)這樣的事情: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)驗(yàn) 獲得超3個(gè)贊
我經(jīng)常會(huì)誤認(rèn)為.SubcribeOn
用來(lái)設(shè)置.Subscribe
執(zhí)行內(nèi)部代碼的線程。但是要記住,只是認(rèn)為發(fā)布和訂閱必須像陰陽(yáng)配對(duì)。設(shè)置Subscribe's code
執(zhí)行位置ObserveOn
。設(shè)置Observable's code
執(zhí)行位置SubscribeOn
?;蛟诳偨Y(jié)口頭禪:where-what
,Subscribe-Observe
,Observe-Subscribe
。
- 3 回答
- 0 關(guān)注
- 1389 瀏覽
添加回答
舉報(bào)
0/150
提交
取消