रिएक्टिव थ्रॉटल रिटर्निंग सभी आइटम TimeSpan

Question

एक IObservable<T> को देखते हुए भीतर जोड़ा वहाँ Throttle व्यवहार (एक टाइमर जब एक आइटम जोड़ा जाता है रीसेट का उपयोग करने के लिए एक रास्ता है, लेकिन यह है कि समय के भीतर जोड़ सभी वस्तुओं का संग्रह वापसी है?

Buffer है कि यह हर बार अवधि या गिनती पर IList<T> में डेटा हिस्सा एक इसी तरह की सुविधा प्रदान करता है। लेकिन मैं हर बार एक आइटम जोड़ा जाता है पुनर्स्थापित करने के लिए उस समय की जरूरत है।

मैं यहाँ एक ऐसी ही सवाल देखा है, Does reactive extensions support rolling buffers?, लेकिन उत्तर आदर्श नहीं लगते हैं और यह थोड़ा पुराना है इसलिए मुझे आश्चर्य हुआ कि क्या आरएक्स-मेन का रिलीज़ संस्करण अब इसका समर्थन करता है बॉक्स के बाहर कार्यक्षमता।

Answer 1

जैसा कि मैं answered in the other post, हाँ आप कर सकते हैं! Observable की Throttle और Window तरीकों का उपयोग करना:

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

यह

Observable.BufferWithTimeOrCount<TSource> Method (IObservable<TSource>, TimeSpan, Int32) के साथ काम नहीं करेंगे?