Observable.Window<TSource, метод TWindowClosing> (IObservable<TSource>, Func<IObservable<TWindowClosing>>)
Проецирование каждого элемента наблюдаемой последовательности в последовательных неперекрывающихся окон.
Пространство имен:System.Reactive.Linq
Сборки: System.Reactive (в System.Reactive.dll)
Синтаксис
'Declaration
<ExtensionAttribute> _
Public Shared Function Window(Of TSource, TWindowClosing) ( _
source As IObservable(Of TSource), _
windowClosingSelector As Func(Of IObservable(Of TWindowClosing)) _
) As IObservable(Of IObservable(Of TSource))
'Usage
Dim source As IObservable(Of TSource)
Dim windowClosingSelector As Func(Of IObservable(Of TWindowClosing))
Dim returnValue As IObservable(Of IObservable(Of TSource))
returnValue = source.Window(windowClosingSelector)
public static IObservable<IObservable<TSource>> Window<TSource, TWindowClosing>(
this IObservable<TSource> source,
Func<IObservable<TWindowClosing>> windowClosingSelector
)
[ExtensionAttribute]
public:
generic<typename TSource, typename TWindowClosing>
static IObservable<IObservable<TSource>^>^ Window(
IObservable<TSource>^ source,
Func<IObservable<TWindowClosing>^>^ windowClosingSelector
)
static member Window :
source:IObservable<'TSource> *
windowClosingSelector:Func<IObservable<'TWindowClosing>> -> IObservable<IObservable<'TSource>>
JScript does not support generic types and methods.
Параметры типа
- TSource
Тип источника.
- TWindowClosing
Тип закрытия окна.
Параметры
- source
Тип: System.IObservable<TSource>
Исходная последовательность для создания окон.
- windowClosingSelector
Тип: System.Func<IObservable<TWindowClosing>>
Функция, вызываемая для определения границ созданных окон.
Возвращаемое значение
Тип: System.IObservable<IObservable<TSource>>
Наблюдаемая последовательность окон.
Примечание об использовании
В Visual Basic и C# этот метод можно вызвать как метод экземпляра для любого объекта типа IObservable<TSource>. При вызове метода для экземпляра следует опускать первый параметр. Дополнительные сведения см. в разделе или .
Комментарии
Оператор Window разбивает наблюдаемую последовательность на последовательных неперекрывающихся окон. Конец текущего окна и начало следующего окна управляются наблюдаемой последовательностью, которая является результатом функции windowClosingSelect , которая передается оператору в качестве входного параметра. Оператор можно использовать для группировки набора событий в окно. Например, состояния транзакции могут быть наблюдаемой main последовательностью. К этим состояниям могут относиться: Подготовка, Подготовлено, Активно и Зафиксировано или прервано. Последовательность main может включать все эти состояния, которые происходят в указанном порядке. Функция windowClosingSelect может возвращать наблюдаемую последовательность, которая создает значение только для состояний Committed или Abort. Это приведет к закрытию окна, представляющего события транзакции для конкретной транзакции.
Примеры
В следующем простом примере последовательность целых чисел разбивается на последовательных неперекрывающихся окон. Конец текущего окна и начало следующего окна управляются наблюдаемой последовательностью целых чисел, создаваемых оператором Interval каждые шесть секунд. Так как main наблюдаемая последовательность создает элемент каждые секунды, в каждом окне будет шесть элементов. Пример кода записывает каждое окно целых чисел в окно консоли вместе с меткой времени, которая показывает, что новое окно открывается каждые шесть секунд.
using System;
using System.Reactive.Linq;
namespace Example
{
class Program
{
static void Main()
{
//*********************************************************************************************//
//*** The mainSequence produces a new long integer from the Interval operator every sec but ***//
//*** this sequence is broken up by the Window operator into subsets like a windowed ***//
//*** view of the sequence. The time when each window stops and the next window starts is ***//
//*** controlled by the IObservable<TWindowClosing> named seqWindowControl. It is returned ***//
//*** by the lambda expression which is passed to the Window operator. In this case it ***//
//** returns another IObservable<long> generated by the Interval operator. So whenever ***//
//*** seqWindowControl produces a item, the current window into the mainSequence stops and ***//
//*** a new window starts. ***//
//*********************************************************************************************//
var mainSequence = Observable.Interval(TimeSpan.FromSeconds(1));
var seqWindowed = mainSequence.Window(() =>
{
var seqWindowControl = Observable.Interval(TimeSpan.FromSeconds(6));
return seqWindowControl;
});
//*********************************************************************************************//
//*** A subscription to seqWindowed will provide a new IObservable<long> every 6 secs. ***//
//*** ***//
//*** Create a subscription to each window into the main sequence and list the values along ***//
//*** with the time the window was opened and the previous window was closed. ***//
//*********************************************************************************************//
seqWindowed.Subscribe(seqWindow =>
{
Console.WriteLine("\nA new window into the main sequence has opened: {0}\n",DateTime.Now.ToString());
seqWindow.Subscribe(x =>
{
Console.WriteLine("Integer : {0}", x);
});
});
Console.ReadLine();
}
}
}
Приведенные ниже выходные данные были созданы в примере кода.
A new window into the main sequence has opened: 6/1/2011 8:48:43 PM
Integer : 0
Integer : 1
Integer : 2
Integer : 3
Integer : 4
Integer : 5
A new window into the main sequence has opened: 6/1/2011 8:48:49 PM
Integer : 6
Integer : 7
Integer : 8
Integer : 9
Integer : 10
Integer : 11
A new window into the main sequence has opened: 6/1/2011 8:48:55 PM
Integer : 12
Integer : 13
Integer : 14
Integer : 15
Integer : 16
Integer : 17
A new window into the main sequence has opened: 6/1/2011 8:49:02 PM
Integer : 18
Integer : 19
Integer : 20
Integer : 21
Integer : 22
Integer : 23