RemoteProvider Class

  • Article

Provides extension methods supporting definition, deployment, retrieval of and transition between sequences and temporal streams.

Inheritance Hierarchy

System.Object
  Microsoft.ComplexEventProcessing.Linq.RemoteProvider

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

Syntax

'Declaration
<ExtensionAttribute> _
Public NotInheritable Class RemoteProvider
'Usage

public static class RemoteProvider

[ExtensionAttribute]
public ref class RemoteProvider abstract sealed

[<AbstractClassAttribute>]
[<SealedAttribute>]
type RemoteProvider =  class end

public final class RemoteProvider

The RemoteProvider type exposes the following members.

Methods

  Name Description
Public methodStatic member Bind<TElement>(IQueryable<TElement>, IRemoteObserver<TElement>) Binds an enumerable sequence to an observer.
Public methodStatic member Bind<TElement>(IQbservable<TElement>, IRemoteObserver<TElement>) Binds observable source to observer sink.
Public methodStatic member Bind<TPayload>(IQStreamable<TPayload>, IRemoteObserver<EdgeEvent<TPayload>>) Binds temporal stream to edge event observer sink.
Public methodStatic member Bind<TPayload>(IQStreamable<TPayload>, IRemoteObserver<IntervalEvent<TPayload>>) Binds temporal stream to interval event observer sink.
Public methodStatic member Bind<TPayload>(IQStreamable<TPayload>, IRemoteObserver<PointEvent<TPayload>>) Binds temporal stream to point event observer sink.
Public methodStatic member Bind<TPayload>(IQStreamable<TPayload>, IRemoteObserver<TPayload>) Binds temporal stream to observer sink.
Public methodStatic member Bind<TPayload>(IQStreamable<TPayload>, IRemoteStreamableSink<TPayload>) Binds temporal stream source to temporal stream sink.
Public methodStatic member Bind<TPayload>(IQStreamable<TPayload>, Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<EdgeEvent<TPayload>>>) Binds temporal stream to edge event observer parameterized on high-water mark and offset.
Public methodStatic member Bind<TPayload>(IQStreamable<TPayload>, Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<IntervalEvent<TPayload>>>) Binds temporal stream to interval event observer parameterized on high-water mark and offset.
Public methodStatic member Bind<TPayload>(IQStreamable<TPayload>, Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<PointEvent<TPayload>>>) Binds temporal stream to point event observer parameterized on high-water mark and offset.
Public methodStatic member Bind<TElement>(IQueryable<TElement>, IRemoteObserver<TElement>, IScheduler) Binds an enumerable sequence to an observer.
Public methodStatic member CreateSubject<TSource, TResult> Defines and deploys a remote subject.
Public methodStatic member DefineEnumerable<TElement>(IRemoteProvider, Expression<Func<IEnumerable<TElement>>>) Defines a remote sequence.
Public methodStatic member DefineEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, TElement>(IRemoteProvider, Expression<Func<T1, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, T2, TElement>(IRemoteProvider, Expression<Func<T1, T2, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, T2, T3, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, T2, T3, T4, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, T2, T3, T4, T5, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, T2, T3, T4, T5, T6, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, T2, T3, T4, T5, T6, T7, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, IEnumerable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<TElement>(IRemoteProvider, Expression<Func<IObservable<TElement>>>) Defines a remote sequence.
Public methodStatic member DefineObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, TElement>(IRemoteProvider, Expression<Func<T1, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, T2, TElement>(IRemoteProvider, Expression<Func<T1, T2, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, T2, T3, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, T2, T3, T4, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, T2, T3, T4, T5, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, T2, T3, T4, T5, T6, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, T2, T3, T4, T5, T6, T7, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObservable<T1, T2, T3, T4, T5, T6, T7, T8, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, IObservable<TElement>>>) Defines a remote function that returns a sequence.
Public methodStatic member DefineObserver<TElement>(IRemoteProvider, Expression<Func<IObserver<TElement>>>) Defines a remote observer.
Public methodStatic member DefineObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IObserver<TElement>>>) Defines a remote function that returns a observer.
Public methodStatic member DefineObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineObserver<T1, TElement>(IRemoteProvider, Expression<Func<T1, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineObserver<T1, T2, TElement>(IRemoteProvider, Expression<Func<T1, T2, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineObserver<T1, T2, T3, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineObserver<T1, T2, T3, T4, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineObserver<T1, T2, T3, T4, T5, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineObserver<T1, T2, T3, T4, T5, T6, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineObserver<T1, T2, T3, T4, T5, T6, T7, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineObserver<T1, T2, T3, T4, T5, T6, T7, T8, TElement>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, IObserver<TElement>>>) Defines a remote function that returns an observer.
Public methodStatic member DefineStreamable<TPayload>(IRemoteProvider, Expression<Func<IStreamable<TPayload>>>) Defines a remote temporal stream.
Public methodStatic member DefineStreamable<TPayload>(IRemoteProvider, Type, Object, EventShape, AdvanceTimeSettings) Defines a remote temporal stream.
Public methodStatic member DefineStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, TPayload>(IRemoteProvider, Expression<Func<T1, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, T2, TPayload>(IRemoteProvider, Expression<Func<T1, T2, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, T2, T3, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, T2, T3, T4, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, T2, T3, T4, T5, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, T2, T3, T4, T5, T6, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, T2, T3, T4, T5, T6, T7, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamable<T1, T2, T3, T4, T5, T6, T7, T8, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, IStreamable<TPayload>>>) Defines a remote function that returns a temporal stream.
Public methodStatic member DefineStreamableSink<TPayload>(IRemoteProvider, Type, Object, EventShape, StreamEventOrder) Defines a remote temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, TPayload>(IRemoteProvider, Expression<Func<T1, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, TPayload>(IRemoteProvider, Expression<Func<T1, T2, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, T3, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, T3, T4, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, T3, T4, T5, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, T3, T4, T5, T6, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, T3, T4, T5, T6, T7, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member DefineStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, TPayload>(IRemoteProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, IStreamableSink<TPayload>>>) Defines a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<TElement>(IQueryable<TElement>, String) Deploys a remote sequence.
Public methodStatic member Deploy<TElement>(IQbservable<TElement>, String) Deploys a remote sequence.
Public methodStatic member Deploy<TPayload>(IQStreamable<TPayload>, String) Deploys a remote temporal stream.
Public methodStatic member Deploy<TElement>(IRemoteObserver<TElement>, String) Deploys a remote observer.
Public methodStatic member Deploy<TPayload>(IRemoteStreamableSink<TPayload>, String) Deploys a remote temporal stream sink.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, TElement>(Func<T1, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, TElement>(Func<T1, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, TPayload>(Func<T1, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, TElement>(Func<T1, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, TPayload>(Func<T1, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, T2, TElement>(Func<T1, T2, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, TElement>(Func<T1, T2, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, TPayload>(Func<T1, T2, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, TElement>(Func<T1, T2, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, TPayload>(Func<T1, T2, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, T2, T3, TElement>(Func<T1, T2, T3, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, TElement>(Func<T1, T2, T3, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, TPayload>(Func<T1, T2, T3, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, T3, TElement>(Func<T1, T2, T3, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, T3, TPayload>(Func<T1, T2, T3, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, T2, T3, T4, TElement>(Func<T1, T2, T3, T4, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, TElement>(Func<T1, T2, T3, T4, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, TPayload>(Func<T1, T2, T3, T4, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, T3, T4, TElement>(Func<T1, T2, T3, T4, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, T3, T4, TPayload>(Func<T1, T2, T3, T4, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, TElement>(Func<T1, T2, T3, T4, T5, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, TElement>(Func<T1, T2, T3, T4, T5, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, TPayload>(Func<T1, T2, T3, T4, T5, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, TElement>(Func<T1, T2, T3, T4, T5, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, TPayload>(Func<T1, T2, T3, T4, T5, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, TElement>(Func<T1, T2, T3, T4, T5, T6, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, TElement>(Func<T1, T2, T3, T4, T5, T6, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, TPayload>(Func<T1, T2, T3, T4, T5, T6, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, TElement>(Func<T1, T2, T3, T4, T5, T6, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, TPayload>(Func<T1, T2, T3, T4, T5, T6, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, IQueryable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, IQbservable<TElement>>, String) Deploys a remote function that returns a sequence.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, IQStreamable<TPayload>>, String) Deploys a remote function that returns a temporal stream.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, TElement>(Func<T1, T2, T3, T4, T5, T6, T7, T8, IRemoteObserver<TElement>>, String) Deploys a remote function that returns an observer.
Public methodStatic member Deploy<T1, T2, T3, T4, T5, T6, T7, T8, TPayload>(Func<T1, T2, T3, T4, T5, T6, T7, T8, IRemoteStreamableSink<TPayload>>, String) Deploys a remote function that returns a temporal stream sink.
Public methodStatic member GetEnumerable<TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, T3, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, T3, T4, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, T3, T4, T5, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, T3, T4, T5, T6, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, T3, T4, T5, T6, T7, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetEnumerable<T1, T2, T3, T4, T5, T6, T7, T8, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<TElement>(IRemoteProvider, String) Retrieves a remote sequence.
Public methodStatic member GetObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, T2, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, T2, T3, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, T2, T3, T4, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, T2, T3, T4, T5, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, T2, T3, T4, T5, T6, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, T2, T3, T4, T5, T6, T7, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObservable<T1, T2, T3, T4, T5, T6, T7, T8, TElement>(IRemoteProvider, String) Retrieves a remote function that returns a sequence.
Public methodStatic member GetObserver<TElement>(IRemoteProvider, String) Retrieves a remote observer.
Public methodStatic member GetObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, T2, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, T2, T3, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, T2, T3, T4, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, T2, T3, T4, T5, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, T2, T3, T4, T5, T6, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, T2, T3, T4, T5, T6, T7, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetObserver<T1, T2, T3, T4, T5, T6, T7, T8, TElement>(IRemoteProvider, String) Retrieves a remote function that returns an observer.
Public methodStatic member GetStreamable<TPayload>(IRemoteProvider, String) Retrieves a remote temporal stream.
Public methodStatic member GetStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, T2, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, T2, T3, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, T2, T3, T4, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, T2, T3, T4, T5, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, T2, T3, T4, T5, T6, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, T2, T3, T4, T5, T6, T7, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamable<T1, T2, T3, T4, T5, T6, T7, T8, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream.
Public methodStatic member GetStreamableSink<TPayload>(IRemoteProvider, String) Retrieves a remote temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, T3, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, T3, T4, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, T3, T4, T5, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, T3, T4, T5, T6, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, T3, T4, T5, T6, T7, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetStreamableSink<T1, T2, T3, T4, T5, T6, T7, T8, TPayload>(IRemoteProvider, String) Retrieves a remote function that returns a temporal stream sink.
Public methodStatic member GetSubject<TSource, TResult> Retrieves a remote subject.
Public methodStatic member Multicast<TSource> Defines a streamable binding based given a source.
Public methodStatic member Subscribe<TElement>(IQueryable<TElement>, IRemoteObserver<TElement>) Subscribes an observer to an enumerable sequence with the specified source and observer.
Public methodStatic member Subscribe<TElement>(IQueryable<TElement>, IRemoteObserver<TElement>, IScheduler) Subscribes an observer to an enumerable sequence with the specified source, observer and scheduler.
Public methodStatic member ToEdgeEnumerable<TPayload> Converts temporal stream to sequence.
Public methodStatic member ToEdgeObservable<TPayload> Converts temporal stream to sequence.
Public methodStatic member ToEdgeStreamable<TSource, TPayload>(Func<Nullable<DateTimeOffset>, IQueryable<TSource>>, Expression<Func<TSource, EdgeEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence parameterized on high-water mark for replay in checkpoints to temporal stream.
Public methodStatic member ToEdgeStreamable<TSource, TPayload>(Func<Nullable<DateTimeOffset>, IQbservable<TSource>>, Expression<Func<TSource, EdgeEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence parameterized on high-water mark for replay in checkpoints to temporal stream.
Public methodStatic member ToEdgeStreamable<TSource, TPayload>(IQueryable<TSource>, Expression<Func<TSource, EdgeEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence to temporal stream.
Public methodStatic member ToEdgeStreamable<TSource, TPayload>(IQbservable<TSource>, Expression<Func<TSource, EdgeEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence to temporal stream.
Public methodStatic member ToEnumerable<TElement>(IQbservable<TElement>) Converts an observable sequence to an enumerable sequence.
Public methodStatic member ToEnumerable<TPayload>(IQStreamable<TPayload>, StreamEventOrder) Converts temporal stream to sequence.
Public methodStatic member ToIntervalEnumerable<TPayload> Converts temporal stream to sequence.
Public methodStatic member ToIntervalObservable<TPayload> Converts temporal stream to sequence.
Public methodStatic member ToIntervalStreamable<TSource, TPayload>(Func<Nullable<DateTimeOffset>, IQueryable<TSource>>, Expression<Func<TSource, IntervalEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence parameterized on high-water mark for replay in checkpoints to temporal stream.
Public methodStatic member ToIntervalStreamable<TSource, TPayload>(Func<Nullable<DateTimeOffset>, IQbservable<TSource>>, Expression<Func<TSource, IntervalEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence parameterized on high-water mark for replay in checkpoints to temporal stream.
Public methodStatic member ToIntervalStreamable<TSource, TPayload>(IQueryable<TSource>, Expression<Func<TSource, IntervalEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence to temporal stream.
Public methodStatic member ToIntervalStreamable<TSource, TPayload>(IQbservable<TSource>, Expression<Func<TSource, IntervalEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence to temporal stream.
Public methodStatic member ToObservable<TElement>(IQueryable<TElement>) Converts an enumerable sequence to an observable sequence.
Public methodStatic member ToObservable<TElement>(IQueryable<TElement>, IScheduler) Converts an enumerable sequence to an observable sequence with a specified source and scheduler.
Public methodStatic member ToObservable<TPayload>(IQStreamable<TPayload>, StreamEventOrder) Converts temporal stream to sequence.
Public methodStatic member ToPointEnumerable<TPayload> Converts temporal stream to sequence.
Public methodStatic member ToPointObservable<TPayload> Converts temporal stream to sequence.
Public methodStatic member ToPointStreamable<TSource, TPayload>(Func<Nullable<DateTimeOffset>, IQueryable<TSource>>, Expression<Func<TSource, PointEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence parameterized on high-water mark for replay in checkpoints to temporal stream.
Public methodStatic member ToPointStreamable<TSource, TPayload>(Func<Nullable<DateTimeOffset>, IQbservable<TSource>>, Expression<Func<TSource, PointEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence parameterized on high-water mark for replay in checkpoints to temporal stream.
Public methodStatic member ToPointStreamable<TSource, TPayload>(IQueryable<TSource>, Expression<Func<TSource, PointEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence to temporal stream.
Public methodStatic member ToPointStreamable<TSource, TPayload>(IQbservable<TSource>, Expression<Func<TSource, PointEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence to temporal stream.
Public methodStatic member ToStreamable<TPayload>(Func<Nullable<DateTimeOffset>, IQueryable<EdgeEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence parameterized on high-water mark for replay in checkpoints to temporal stream.
Public methodStatic member ToStreamable<TPayload>(Func<Nullable<DateTimeOffset>, IQbservable<EdgeEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence parameterized on high-water mark for replay in checkpoints to temporal stream.
Public methodStatic member ToStreamable<TPayload>(IQueryable<EdgeEvent<TPayload>>, AdvanceTimeSettings) Converts sequence to temporal stream.
Public methodStatic member ToStreamable<TPayload>(IQbservable<EdgeEvent<TPayload>>, AdvanceTimeSettings) Converts sequence to temporal stream.
Public methodStatic member ToStreamable<TPayload>(Func<Nullable<DateTimeOffset>, IQueryable<IntervalEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence parameterized on high-water mark for replay in checkpoints to temporal stream.
Public methodStatic member ToStreamable<TPayload>(Func<Nullable<DateTimeOffset>, IQbservable<IntervalEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence parameterized on high-water mark for replay in checkpoints to temporal stream.
Public methodStatic member ToStreamable<TPayload>(IQueryable<IntervalEvent<TPayload>>, AdvanceTimeSettings) Converts sequence to temporal stream.
Public methodStatic member ToStreamable<TPayload>(IQbservable<IntervalEvent<TPayload>>, AdvanceTimeSettings) Converts sequence to temporal stream.
Public methodStatic member ToStreamable<TPayload>(Func<Nullable<DateTimeOffset>, IQueryable<PointEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence parameterized on high-water mark for replay in checkpoints to temporal stream.
Public methodStatic member ToStreamable<TPayload>(Func<Nullable<DateTimeOffset>, IQbservable<PointEvent<TPayload>>>, AdvanceTimeSettings) Converts sequence parameterized on high-water mark for replay in checkpoints to temporal stream.
Public methodStatic member ToStreamable<TPayload>(IQueryable<PointEvent<TPayload>>, AdvanceTimeSettings) Converts sequence to temporal stream.
Public methodStatic member ToStreamable<TPayload>(IQbservable<PointEvent<TPayload>>, AdvanceTimeSettings) Converts sequence to temporal stream.
Public methodStatic member With(IRemoteBinding, IRemoteBinding)
Public methodStatic member With(IRemoteStreamableBinding, IRemoteStreamableBinding)

Top

Thread Safety

Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.

See Also

Reference

Microsoft.ComplexEventProcessing.Linq Namespace