ObservableCepStream.ToIntervalObservable<TPayload> Method (CepStream<TPayload>)
Converts a CepStream of interval events to an event sink that implements the IObservable interface. The order of events is FullyOrdered.
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing.Observable (in Microsoft.ComplexEventProcessing.Observable.dll)
Syntax
public static ICepObservable<IntervalEvent<TPayload>> ToIntervalObservable<TPayload>(
this CepStream<TPayload> stream
)
public:
generic<typename TPayload>
[ExtensionAttribute]
static ICepObservable<IntervalEvent<TPayload>^>^ ToIntervalObservable(
CepStream<TPayload>^ stream
)
static member ToIntervalObservable<'TPayload> :
stream:CepStream<'TPayload> -> ICepObservable<IntervalEvent<'TPayload>>
<ExtensionAttribute>
Public Shared Function ToIntervalObservable(Of TPayload) (
stream As CepStream(Of TPayload)
) As ICepObservable(Of IntervalEvent(Of TPayload))
Parameters
stream
Type: Microsoft.ComplexEventProcessing.Linq.CepStream<TPayload>The fully bound event source from which the observable event sink is created.
Return Value
Type: Microsoft.ComplexEventProcessing.Linq.ICepObservable<IntervalEvent<TPayload>>
An event sink that supports observation.
Type Parameters
- TPayload
Type of the event payload.
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 Event Structure.
See Also
ToIntervalObservable Overload
ObservableCepStream Class
Microsoft.ComplexEventProcessing.Linq Namespace
Return to top