У меня есть класс, который принимает поток событий и выталкивает другой поток событий.
Все события используют Reactive Extensions (RX). Входящий поток событий выталкивается из внешнего источника в IObserver<T>
с помощью .OnNext
, а исходящий поток событий выталкивается с помощью IObservable<T>
и .Subscribe
. Я использую Subject<T>
для управления этим за кулисами.
Мне интересно, какие методы есть в RX для временной приостановки вывода. Это будет означать, что входящие события будут накапливаться во внутренней очереди, и когда они будут возобновлены, события снова будут вытекать.
IObserver<T>
, не так ли? - person Enigmativity   schedule 13.07.2015Subject<T>
вIObserver<T>
, чтобы можно было раскрыть метод.OnNext
. - person Contango   schedule 14.07.2015