IRemoteSubject<TSource, TResult> Interface
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 | |
---|---|---|
ElementType | (Inherited from IQbservable.) | |
Expression | (Inherited from IQbservable.) | |
Provider | (Inherited from IQbservable.) |
Top
Methods
Name | Description | |
---|---|---|
Dispose | (Inherited from IDisposable.) | |
OnCompleted | (Inherited from IObserver<TSource>.) | |
OnError | (Inherited from IObserver<TSource>.) | |
OnNext | (Inherited from IObserver<TSource>.) | |
Subscribe | (Inherited from IObservable<TResult>.) |
Top
Extension Methods
Name | Description | |
---|---|---|
Bind<TResult> | Binds observable source to observer sink. (Defined by RemoteProvider.) | |
Deploy<TResult>(String) | Overloaded. Deploys a remote sequence. (Defined by RemoteProvider.) | |
Deploy<TSource>(String) | Overloaded. Deploys a remote observer. (Defined by RemoteProvider.) | |
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.) | |
ToEdgeStreamable<TResult, TPayload> | Converts sequence to temporal stream. (Defined by RemoteProvider.) | |
ToEnumerable<TResult> | Converts an observable sequence to an enumerable sequence. (Defined by RemoteProvider.) | |
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.) | |
ToIntervalStreamable<TResult, TPayload> | Converts sequence to temporal stream. (Defined by RemoteProvider.) | |
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.) | |
ToPointStreamable<TResult, TPayload> | Converts sequence to temporal stream. (Defined by RemoteProvider.) |
Top