reattiva Throttle Tornando tutti gli articoli inseriti da meno il periodo che hai

Question

Dato un IObservable<T> c'è un modo per utilizzare Throttle comportamento (azzerare un timer quando si aggiunge un elemento, ma lo hanno restituire un insieme di tutti gli elementi aggiunti all'interno di quel tempo?

Buffer fornisce una funzionalità simile è che bei pezzi i dati su in IList<T> su ogni intervallo di tempo o contare. Ma ho bisogno che il tempo per reimpostare ogni volta che viene aggiunto un elemento.

ho visto una domanda simile qui, Does reactive extensions support rolling buffers?, ma le risposte non sembrano ideali ed è un po 'vecchio quindi mi sono chiesto se la versione di Rx-Main ora supporta questo funzionalità fuori dagli schemi.

Answer 1

Come I answered in the other post, sì, è possibile! Utilizzando le Throttle e Window metodi di Observable:

public static IObservable<IList<T>> BufferUntilInactive<T>(this IObservable<T> stream, TimeSpan delay) 
{ 
    var closes = stream.Throttle(delay); 
    return stream.Window(() => closes).SelectMany(window => window.ToList()); 
} 

Answer 2

Non sarebbe lavorare con

Observable.BufferWithTimeOrCount<TSource> Method (IObservable<TSource>, TimeSpan, Int32)?