Skip to content

,System.Func{System.IObservable{--1}})} ,System.IObservable{--1},System.Func{--1,System.IObservable{--2}})} ,System.IObservable{--1})} ,System.Int32)} ,System.Int32,System.Int32)} ,System.TimeSpan)} ,System.TimeSpan,System.Reactive.Concurrency.IScheduler)} ,System.TimeSpan,System.TimeSpan)} ,System.TimeSpan,System.TimeSpan,System.Reactive.Concurrency.IScheduler)} ,System.TimeSpan,System.Int32)} ,System.TimeSpan,System.Int32,System.Reactive.Concurrency.IScheduler)}

Observable.Window(IObservable, Func>) method

Defined in

Type: Observable Namespace: System.Reactive.Linq Assembly: System.Reactive.dll

Applies to

net8.0, net8.0-windows10.0.19041, netstandard2.0

Overloads

  1. public static IObservable<IObservable<TSource>> Window<TSource, TWindowClosing>(this IObservable<TSource> source, Func<IObservable<TWindowClosing>> windowClosingSelector)

  2. public static IObservable<IObservable<TSource>> Window<TSource, TWindowOpening, TWindowClosing>(this IObservable<TSource> source, IObservable<TWindowOpening> windowOpenings, Func<TWindowOpening, IObservable<TWindowClosing>> windowClosingSelector)

  3. public static IObservable<IObservable<TSource>> Window<TSource, TWindowBoundary>(this IObservable<TSource> source, IObservable<TWindowBoundary> windowBoundaries)

  4. public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, int count)

  5. public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, int count, int skip)

  6. public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan)

  7. public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, IScheduler scheduler)

  8. public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, TimeSpan timeShift)

  9. public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, TimeSpan timeShift, IScheduler scheduler)

  10. public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, int count)

  11. public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, int count, IScheduler scheduler)

1. Overload

public static IObservable<IObservable<TSource>> Window<TSource, TWindowClosing>(this IObservable<TSource> source, Func<IObservable<TWindowClosing>> windowClosingSelector)

Type parameters

NameDescription
TSource--
TWindowClosing--

Parameters

NameTypeDescription
sourceIObservable--
windowClosingSelectorFunc>--

Returns: IObservable>

2. Overload

public static IObservable<IObservable<TSource>> Window<TSource, TWindowOpening, TWindowClosing>(this IObservable<TSource> source, IObservable<TWindowOpening> windowOpenings, Func<TWindowOpening, IObservable<TWindowClosing>> windowClosingSelector)

Type parameters

NameDescription
TSource--
TWindowOpening--
TWindowClosing--

Parameters

NameTypeDescription
sourceIObservable--
windowOpeningsIObservable--
windowClosingSelectorFunc>--

Returns: IObservable>

3. Overload

public static IObservable<IObservable<TSource>> Window<TSource, TWindowBoundary>(this IObservable<TSource> source, IObservable<TWindowBoundary> windowBoundaries)

Type parameters

NameDescription
TSource--
TWindowBoundary--

Parameters

NameTypeDescription
sourceIObservable--
windowBoundariesIObservable--

Returns: IObservable>

4. Overload

public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, int count)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
sourceIObservable--
countint--

Returns: IObservable>

5. Overload

public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, int count, int skip)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
sourceIObservable--
countint--
skipint--

Returns: IObservable>

6. Overload

public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
sourceIObservable--
timeSpanTimeSpan--

Returns: IObservable>

7. Overload

public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, IScheduler scheduler)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
sourceIObservable--
timeSpanTimeSpan--
scheduler[IScheduler](#--

Returns: IObservable>

8. Overload

public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, TimeSpan timeShift)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
sourceIObservable--
timeSpanTimeSpan--
timeShiftTimeSpan--

Returns: IObservable>

9. Overload

public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, TimeSpan timeShift, IScheduler scheduler)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
sourceIObservable--
timeSpanTimeSpan--
timeShiftTimeSpan--
scheduler[IScheduler](#--

Returns: IObservable>

10. Overload

public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, int count)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
sourceIObservable--
timeSpanTimeSpan--
countint--

Returns: IObservable>

11. Overload

public static IObservable<IObservable<TSource>> Window<TSource>(this IObservable<TSource> source, TimeSpan timeSpan, int count, IScheduler scheduler)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
sourceIObservable--
timeSpanTimeSpan--
countint--
scheduler[IScheduler](#--

Returns: IObservable>