ICepObservable<T> Interface

 

Represents an extended observable interface supporting named queries for subscriptions.

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

public interface ICepObservable<T> : IObservable<T>

Type Parameters

T

The element type that provides notification information.

NameDescription
System_CAPS_pubmethodSubscribe(IObserver<T>)

(Inherited from IObservable<T>.)

System_CAPS_pubmethodSubscribe(IObserver<T>, String, String)

Creates and observes results from a query with the given name and description.

NameDescription
System_CAPS_pubmethodSelect<TInput, TOutput>(Expression<Func<TInput, TOutput>>)

Projects each event of an observable input stream into a new event.(Defined by ObservableCepStream.)

System_CAPS_pubmethodToEdgeStream<T, TPayload>(Application, Expression<Func<T, EdgeEvent<TPayload>>>, AdvanceTimeSettings, String)

Converts an observable input stream to a stream of edge events, and provides the temporal characteristics of the input.(Defined by ObservableCepStream.)

System_CAPS_pubmethodToIntervalStream<T, TPayload>(Application, Expression<Func<T, IntervalEvent<TPayload>>>, AdvanceTimeSettings, String)

Converts an observable input stream to a stream of interval events, and provides the temporal characteristics of the input.(Defined by ObservableCepStream.)

System_CAPS_pubmethodToPointStream<T, TPayload>(Application, Expression<Func<T, PointEvent<TPayload>>>, AdvanceTimeSettings, String)

Converts an observable input stream to a stream of point events, and provides the temporal characteristics of the input.(Defined by ObservableCepStream.)

System_CAPS_pubmethodWhere<TInput>(Expression<Func<TInput, Boolean>>)

Filters events from an observable input stream using the specified filter expression.(Defined by ObservableCepStream.)

Return to top
Show: