Method Process

Namespace

Bonsai.Reactive

Assembly

Bonsai.Core.dll

Process<TSource, TBufferOpening>(IObservable<TSource>, IObservable<TBufferOpening>)

Projects each element of an observable sequence into zero or more buffers created when a second sequence emits a notification.

public IObservable<IList<TSource>> Process<TSource, TBufferOpening>(IObservable<TSource> source, IObservable<TBufferOpening> bufferOpenings)

Parameters

source IObservable<TSource>

The source sequence to produce buffers over.

bufferOpenings IObservable<TBufferOpening>

The sequence of buffer openings. If no maximum length is specified, the current buffer is closed and a new buffer is opened upon receiving a notification from this sequence.

Returns

IObservable<IList<TSource>>

An observable sequence of buffers.

Type Parameters

TSource

The type of the elements in the source sequence.

TBufferOpening

The type of the elements in the bufferOpenings sequence.