ObservableCepStream.ToIntervalObservable<TPayload> Method (CepStream<TPayload>, StreamEventOrder)
Converts a CepStream of interval events with the specified event order to an event sink that implements the IObservable interface.
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing.Observable (in Microsoft.ComplexEventProcessing.Observable.dll)
Syntax
'Declaration
<ExtensionAttribute> _
Public Shared Function ToIntervalObservable(Of TPayload) ( _
stream As CepStream(Of TPayload), _
streamEventOrder As StreamEventOrder _
) As ICepObservable(Of IntervalEvent(Of TPayload))
'Usage
Dim stream As CepStream(Of TPayload)
Dim streamEventOrder As StreamEventOrder
Dim returnValue As ICepObservable(Of IntervalEvent(Of TPayload))
returnValue = stream.ToIntervalObservable(streamEventOrder)
public static ICepObservable<IntervalEvent<TPayload>> ToIntervalObservable<TPayload>(
this CepStream<TPayload> stream,
StreamEventOrder streamEventOrder
)
[ExtensionAttribute]
public:
generic<typename TPayload>
static ICepObservable<IntervalEvent<TPayload>^>^ ToIntervalObservable(
CepStream<TPayload>^ stream,
StreamEventOrder streamEventOrder
)
static member ToIntervalObservable :
stream:CepStream<'TPayload> *
streamEventOrder:StreamEventOrder -> ICepObservable<IntervalEvent<'TPayload>>
JScript does not support generic types and methods.
Type Parameters
- TPayload
Type of the event payload.
Parameters
- stream
Type: Microsoft.ComplexEventProcessing.Linq.CepStream<TPayload>
The fully bound event source from which the observable event sink is created.
- streamEventOrder
Type: Microsoft.ComplexEventProcessing.StreamEventOrder
One of the enumeration values that specifies how events are ordered.
Return Value
Type: Microsoft.ComplexEventProcessing.Linq.ICepObservable<IntervalEvent<TPayload>>
An event sink that supports observation.
Usage Note
In Visual Basic and C#, you can call this method as an instance method on any object of type CepStream<TPayload>. When you use instance method syntax to call this method, omit the first parameter. For more information, see https://msdn.microsoft.com/en-us/library/bb384936(v=sql.110) or https://msdn.microsoft.com/en-us/library/bb383977(v=sql.110).
Remarks
Calling the Subscribe method of the observable event sink initializes and starts a query. The query is deleted when the subscription is disposed.
The ICepObservable<T> interface includes an overload of Subscribe that lets you specify a name and description for the query. These additional properties are useful for debugging.
For more information about the data types that are supported in the payload of an event, see Creating Event Types.