Observable.Window<TSource> Method (IObservable<TSource>, TimeSpan)
Projects each element of an observable sequence into consecutive non-overlapping windows which are produced based on timing information.
Namespace: System.Reactive.Linq
Assembly: System.Reactive (in System.Reactive.dll)
public static IObservable<IObservable<TSource>> Window<TSource>( this IObservable<TSource> source, TimeSpan timeSpan )
Type Parameters
- TSource
The type of source.
Parameters
- source
- Type: System.IObservable<TSource>
The source sequence to produce windows over.
- timeSpan
- Type: System.TimeSpan
The length of each window.