Имам клас, който приема поток от събития и изтласква друг поток от събития.
Всички събития използват реактивни разширения (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