반응성 <code>IObservable<T></code> 주어진 시간 범위

Question

내에서 추가 된 모든 항목 Throttle 행동 (항목이 추가되는 타이머를 재설정을 사용하는 방법이 반환 스로틀했지만, 그 때 내에서 추가 된 모든 항목의 컬렉션을 반환해야?

Buffer는 모든 시간 범위 또는 셀에 IList<T>들로 데이터를 청크하는 유사한 기능에게 그것을 제공합니다.하지만 항목이 추가 될 때마다 다시 그 시간이 필요합니다.

내가 여기 비슷한 질문을 본 적이 Does reactive extensions support rolling buffers?,하지만 답변이 이상적으로 보이지 않아 조금 오래되었으므로 Rx-Main의 릴리스 버전이 이제이 기능을 지원하는지 궁금하네요. 상자 밖의 기능.

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) 작동하지 않을까요?