Interface IHigherOrderExecutionEnvironment

This interface supports hosting infrastructure for the operator library in a query engine.

Inherited Members

IExecutionEnvironment.GetSubject<TInput, TOutput>(Uri)

IExecutionEnvironment.GetSubscription(Uri)

Namespace: Reaqtive

Assembly: Reaqtive.Interfaces.dll

Syntax

public interface IHigherOrderExecutionEnvironment : IExecutionEnvironment

Methods

CreateBridge<T>(ISubscribable<T>, IObserver<T>, IOperatorContext)

Creates a bridge for a higher-order input subscription.

Declaration

ISubscription CreateBridge<T>(ISubscribable<T> subscribable, IObserver<T> observer, IOperatorContext parent)

Parameters

Type	Name	Description
ISubscribable<T>	subscribable	The upstream subscribable; should be quoted.
System.IObserver<T>	observer	The volatile downstream observer.
IOperatorContext	parent	The parent context.

Returns

Type	Description
ISubscription	A persistable subscription handle.

Type Parameters

Name	Description
T	The type of the elements.

CreateRefCountSubject<T>(Uri, Uri, Uri, IOperatorContext)

Creates a reference counted subject.

Declaration

IMultiSubject<T, T> CreateRefCountSubject<T>(Uri uri, Uri tollbooth, Uri collector, IOperatorContext parent)

Parameters

Type	Name	Description
System.Uri	uri	The URI used to identify the subject.
System.Uri	tollbooth	The URI of the tollbooth subject (see remarks in HigherOrderOutputStatefulOperatorBase).
System.Uri	collector	The URI of the collector subject (see remarks in HigherOrderOutputStatefulOperatorBase).
IOperatorContext	parent	The parent context.

Returns

Type	Description
IMultiSubject<T, T>	A persisted reference counted subject instance.

Type Parameters

Name	Description
T	The type of the elements.

CreateSimpleSubject<T>(Uri, IOperatorContext)

Creates a simple subject.

Declaration

IMultiSubject<T, T> CreateSimpleSubject<T>(Uri uri, IOperatorContext parent)

Parameters

Type	Name	Description
System.Uri	uri	The URI used to identify the subject.
IOperatorContext	parent	The parent context.

Returns

Type	Description
IMultiSubject<T, T>	A persisted simple subject instance.

Type Parameters

Name	Description
T	The type of the elements.

DeleteSubject<T>(Uri, IOperatorContext)

Deletes a subject.

Declaration

void DeleteSubject<T>(Uri uri, IOperatorContext parent)

Parameters

Type	Name	Description
System.Uri	uri	The URI used to identify the subject to delete.
IOperatorContext	parent	The parent context.

Type Parameters

Name	Description
T	The type of the elements.

LoadBridge<T>(IOperatorStateReader, IObserver<T>, IOperatorContext)

Loads a bridge from checkpoint state.

Declaration

ISubscription LoadBridge<T>(IOperatorStateReader reader, IObserver<T> observer, IOperatorContext parent)

Parameters

Type	Name	Description
IOperatorStateReader	reader	The reader to load from.
System.IObserver<T>	observer	The volatile downstream observer to reconnect.
IOperatorContext	parent	The parent context.

Returns

Type	Description
ISubscription	A persistable subscription handle.

Type Parameters

Name	Description
T	The type of the elements.

Quote<T>(IMultiSubject<T, T>, Uri)

Creates a quoted proxy around the given subject.

Declaration

ISubscribable<T> Quote<T>(IMultiSubject<T, T> subject, Uri uri)

Parameters

Type	Name	Description
IMultiSubject<T, T>	subject	The subject to quote.
System.Uri	uri	The URI of the subject.

Returns

Type	Description
ISubscribable<T>	A proxy to the subject with a quote attached to it.

Type Parameters

Name	Description
T	The type of the elements.

Quote<TKey, TElement>(IGroupedMultiSubject<TKey, TElement>, Uri)

Creates a quoted proxy around the given group subject.

Declaration

IGroupedSubscribable<TKey, TElement> Quote<TKey, TElement>(IGroupedMultiSubject<TKey, TElement> subject, Uri uri)

Parameters

Type	Name	Description
IGroupedMultiSubject<TKey, TElement>	subject	The subject to quote.
System.Uri	uri	The URI of the subject.

Returns

Type	Description
IGroupedSubscribable<TKey, TElement>	A proxy to the subject with a quote attached to it.

Type Parameters

Name	Description
TKey	The type of the keys.
TElement	The type of the elements.

SaveBridge(ISubscription, IOperatorStateWriter, IOperatorContext)

Saves the bridge to checkpoint state.

Declaration

void SaveBridge(ISubscription subscription, IOperatorStateWriter writer, IOperatorContext parent)

Parameters

Type	Name	Description
ISubscription	subscription	The persistable subscription obtained from Create or Load.
IOperatorStateWriter	writer	The writer to write to.
IOperatorContext	parent	The parent context.