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
)

Type Parameters

  • TPayload
    Type of the event payload.

Parameters

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.105) or https://msdn.microsoft.com/en-us/library/bb383977(v=sql.105).

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.

See Also

Reference

ObservableCepStream Class

ToIntervalObservable Overload

Microsoft.ComplexEventProcessing.Linq Namespace