Observable.Window<TSource> Method (IObservable<TSource>, TimeSpan, IScheduler)
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, IScheduler scheduler )
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.
- scheduler
- Type: System.Reactive.Concurrency.IScheduler
The scheduler to run windowing timers on.