сбросить счетчик выше максимального временного интервала при агрегации на основе счетчика Rx

Фильтрация на основе счетчика без ограничения по времени

IObservable filteredStream = changes.Buffer(3);

Как ввести сброс бездействия?

enter image description here

Но как ввести тайм-аут TimeSpan tooLong , чтобы счет начинался с нуля всякий раз, когда интервал между двумя значениями превышает этот максимум?

10
задан Cel 4 March 2012 в 12:40
поделиться