ICepObservable<T> Interface

Extends the IObservable<T> interface to let you specify a query name and description for an observable event source.

Namespace:  Microsoft.ComplexEventProcessing.Linq
Assembly:  Microsoft.ComplexEventProcessing.Observable (in Microsoft.ComplexEventProcessing.Observable.dll)

Syntax

public interface ICepObservable<T> : IObservable<T>

Type Parameters

  • T
    Type of the event

The ICepObservable<T> type exposes the following members.

Methods

  Name Description
Public method Subscribe(IObserver<T>) (Inherited from IObservable<T>.)
Public method Subscribe(IObserver<T>, String, String) Extends the IObservable<T> interface to let you specify a query name and description for an observable event source.

Top

Extension Methods

  Name Description
Public Extension Method Select<TInput, TOutput> Projects each event of an observable input stream into a new event. (Defined by ObservableCepStream.)
Public Extension Method ToEdgeStream<T, TPayload> Converts an observable input stream to a stream of edge events, and provides the temporal characteristics of the input. (Defined by ObservableCepStream.)
Public Extension Method ToIntervalStream<T, TPayload> Converts an observable input stream to a stream of interval events, and provides the temporal characteristics of the input. (Defined by ObservableCepStream.)
Public Extension Method ToPointStream<T, TPayload> Converts an observable input stream to a stream of point events, and provides the temporal characteristics of the input. (Defined by ObservableCepStream.)
Public Extension Method Where<TInput> Filters events from an observable input stream using the specified filter expression. (Defined by ObservableCepStream.)

Top

Remarks

For more information about the interface that ICepObservable<T> extends, see the documentation for the IObservable<T> interface in the MSDN Library.

See Also

Reference

Microsoft.ComplexEventProcessing.Linq Namespace