Export (0) Print
Expand All

IRemoteSubject<TSource, TResult> Interface

Represents an interface for the remote binding.

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

public interface IRemoteSubject<TSource, TResult> : ISubject<TSource, TResult>, 
	IQbservable<TResult>, IQbservable, IObservable<TResult>, IRemoteObserver<TSource>, 
	IObserver<TSource>, IRemote, IDisposable

Type Parameters

TSource

The type of the elements of source.

TResult

The type of the result.

The IRemoteSubject<TSource, TResult> type exposes the following members.

  NameDescription
Public propertyElementType (Inherited from IQbservable.)
Public propertyExpression (Inherited from IQbservable.)
Public propertyProvider (Inherited from IQbservable.)
Top

  NameDescription
Public methodDispose (Inherited from IDisposable.)
Public methodOnCompleted (Inherited from IObserver<TSource>.)
Public methodOnError (Inherited from IObserver<TSource>.)
Public methodOnNext (Inherited from IObserver<TSource>.)
Public methodSubscribe (Inherited from IObservable<TResult>.)
Top

  NameDescription
Public Extension MethodBind<TResult> Binds observable source to observer sink. (Defined by RemoteProvider.)
Public Extension MethodDeploy<TResult>(String)Overloaded. Deploys a remote sequence. (Defined by RemoteProvider.)
Public Extension MethodDeploy<TSource>(String)Overloaded. Deploys a remote observer. (Defined by RemoteProvider.)
Public Extension MethodToEdgeStream<TResult, 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 MethodToEdgeStreamable<TResult, TPayload> Converts sequence to temporal stream. (Defined by RemoteProvider.)
Public Extension MethodToEnumerable<TResult> Converts an observable sequence to an enumerable sequence. (Defined by RemoteProvider.)
Public Extension MethodToIntervalStream<TResult, 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 MethodToIntervalStreamable<TResult, TPayload> Converts sequence to temporal stream. (Defined by RemoteProvider.)
Public Extension MethodToPointStream<TResult, 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 MethodToPointStreamable<TResult, TPayload> Converts sequence to temporal stream. (Defined by RemoteProvider.)
Top
Show:
© 2014 Microsoft