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