Method Process
Process<TSource, TWindowOpening>(IObservable<TSource>, IObservable<TWindowOpening>)
Projects each element of an observable sequence into zero or more windows created when a second sequence emits a notification.
public IObservable<IObservable<TSource>> Process<TSource, TWindowOpening>(IObservable<TSource> source, IObservable<TWindowOpening> windowOpenings)
Parameters
source
IObservable<TSource>The source sequence to produce windows over.
windowOpenings
IObservable<TWindowOpening>The sequence of window openings. If no maximum length is specified, the current window is closed and a new window is opened upon receiving a notification from this sequence.
Returns
- IObservable<IObservable<TSource>>
An observable sequence of windows.
Type Parameters
TSource
The type of the elements in the
source
sequence.TWindowOpening
The type of the elements in the
windowOpenings
sequence.