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)
Syntax
public interface ICepObservable<T> : IObservable<T>
generic<typename T>
public interface class ICepObservable : IObservable<T>
type ICepObservable<'T> =
interface
interface IObservable<'T>
end
Public Interface ICepObservable(Of T)
Inherits IObservable(Of T)
Type Parameters
- T
The element type that provides notification information.
Methods
Name | Description | |
---|---|---|
Subscribe(IObserver<T>) | (Inherited from IObservable<T>.) |
|
Subscribe(IObserver<T>, String, String) | Creates and observes results from a query with the given name and description. |
Extension Methods
Name | Description | |
---|---|---|
Select<TInput, TOutput>(Expression<Func<TInput, TOutput>>) | Projects each event of an observable input stream into a new event.(Defined by ObservableCepStream.) |
|
ToEdgeStream<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.) |
|
ToIntervalStream<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.) |
|
ToPointStream<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.) |
|
Where<TInput>(Expression<Func<TInput, Boolean>>) | Filters events from an observable input stream using the specified filter expression.(Defined by ObservableCepStream.) |
See Also
Microsoft.ComplexEventProcessing.Linq Namespace
Return to top