Reactive Throttle Trở All Items Added Trong Các TimeSpan

Question

Với một IObservable<T> là có một cách để sử dụng Throttle hành vi (reset bộ đếm thời gian khi một mục được thêm vào, nhưng có nó trả về một bộ sưu tập của tất cả các mục được thêm vào trong thời gian đó?

Buffer cung cấp một chức năng tương tự nó rằng nó khối dữ liệu lên IList<T> trên mỗi khoảng thời gian hoặc đếm. Nhưng tôi cần thời gian đó để thiết lập lại mỗi lần một mục được thêm vào.

tôi đã nhìn thấy một câu hỏi tương tự ở đây, Does reactive extensions support rolling buffers?, nhưng câu trả lời dường như không lý tưởng và nó hơi cũ nên tôi tự hỏi liệu phiên bản phát hành của Rx-Main có hỗ trợ điều này không chức năng ra khỏi hộp.

Answer 1

Như tôi answered in the other post, có bạn có thể! Sử dụng phương pháp Throttle và Window của 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

Nó sẽ không hoạt động với

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