IRemoteSubject<TSource, TResult> Interface

  • Article

Represents an interface for the remote binding.

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

Syntax

'Declaration
Public Interface IRemoteSubject(Of TSource, TResult) _
    Inherits ISubject(Of TSource, TResult), IQbservable(Of TResult),  _
    IQbservable, IObservable(Of TResult), IRemoteObserver(Of TSource),  _
    IObserver(Of TSource), IRemote, IDisposable
'Usage
Dim instance As IRemoteSubject(Of TSource, TResult)

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

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

type IRemoteSubject<'TSource, 'TResult> =  
    interface 
        interface ISubject<'TSource, 'TResult>
        interface IQbservable<'TResult>
        interface IQbservable 
        interface IObservable<'TResult>
        interface IRemoteObserver<'TSource>
        interface IObserver<'TSource>
        interface IRemote 
        interface IDisposable 
    end

JScript does not support generic types and methods.

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.

Properties

  Name Description
Public property ElementType (Inherited from IQbservable.)
Public property Expression (Inherited from IQbservable.)
Public property Provider (Inherited from IQbservable.)

Top

Methods

  Name Description
Public method Dispose (Inherited from IDisposable.)
Public method OnCompleted (Inherited from IObserver<TSource>.)
Public method OnError (Inherited from IObserver<TSource>.)
Public method OnNext (Inherited from IObserver<TSource>.)
Public method Subscribe (Inherited from IObservable<TResult>.)

Top

Extension Methods

  Name Description
Public Extension Method Bind<TResult> Binds observable source to observer sink. (Defined by RemoteProvider.)
Public Extension Method Deploy<TResult>(String) Overloaded. Deploys a remote sequence. (Defined by RemoteProvider.)
Public Extension Method Deploy<TSource>(String) Overloaded. Deploys a remote observer. (Defined by RemoteProvider.)
Public Extension Method ToEdgeStream<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 Method ToEdgeStreamable<TResult, TPayload> Converts sequence to temporal stream. (Defined by RemoteProvider.)
Public Extension Method ToEnumerable<TResult> Converts an observable sequence to an enumerable sequence. (Defined by RemoteProvider.)
Public Extension Method ToIntervalStream<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 Method ToIntervalStreamable<TResult, TPayload> Converts sequence to temporal stream. (Defined by RemoteProvider.)
Public Extension Method ToPointStream<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 Method ToPointStreamable<TResult, TPayload> Converts sequence to temporal stream. (Defined by RemoteProvider.)

Top

See Also

Reference

Microsoft.ComplexEventProcessing.Linq Namespace