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
sourceIObservable<TSource>The source sequence to produce windows over.
windowOpeningsIObservable<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
TSourceThe type of the elements in the
sourcesequence.TWindowOpeningThe type of the elements in the
windowOpeningssequence.