Основываясь на чтении этого вопроса: В чем разница между SubscribeOn и ObserveOn
ObserveOn
выполняется набор, в котором находится код в обработчике Subscribe
:
stream.Subscribe(_ => { // this code here });
Метод SubscribeOn
устанавливает, на какой поток выполняется настройка потока.
Я понял, что если они явно не установлены, используется TaskPool.
Теперь мой вопрос: скажем, я делаю что-то вроде этого:
Observable.Interval(new Timespan(0, 0, 1)).Where(t => predicate(t)).SelectMany(t => lots_of(t)).ObserveOnDispatcher().Subscribe(t => some_action(t));
Где выполняются Where
predicate
и SelectMany
lots_of
, учитывая, что some_action
выполняется на диспетчере?