Observable.Buffer<TSource, TBufferOpening, TBufferClosing> Method (IObservable<TSource>, IObservable<TBufferOpening>, Func<TBufferOpening, IObservable<TBufferClosing>>)
Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers.
Namespace: System.Reactive.Linq
Assembly: System.Reactive (in System.Reactive.dll)
public static IObservable<IList<TSource>> Buffer<TSource, TBufferOpening, TBufferClosing>( this IObservable<TSource> source, IObservable<TBufferOpening> bufferOpenings, Func<TBufferOpening, IObservable<TBufferClosing>> bufferClosingSelector )
Type Parameters
- TSource
The type of source.
- TBufferOpening
The type of observable sequence whose elements denote the opening of each produced buffer.
- TBufferClosing
The type of observable sequence whose elements denote the closing of each produced buffer.
Parameters
- source
- Type: System.IObservable<TSource>
The source sequence to produce buffers over.
- bufferOpenings
- Type: System.IObservable<TBufferOpening>
The observable sequence whose elements denote the creation of new buffers.
- bufferClosingSelector
- Type: System.Func<TBufferOpening, IObservable<TBufferClosing>>
The function invoked to define the closing of each produced buffer.
