Class SubscriptionInitializeVisitor
Visitor to initialize subscriptions.
Inheritance
Namespace: Reaqtive
Assembly: Reaqtive.Core.dll
Syntax
public class SubscriptionInitializeVisitor : ObjectConstructors
SubscriptionInitializeVisitor(ISubscription)
Creates a new subscription initialization visitor for the specified subscription.
Declaration
public SubscriptionInitializeVisitor(ISubscription subscription)Parameters
| Type | Name | Description |
|---|---|---|
| ISubscription | subscription | Subscription visited by this visitor. |
Methods
Initialize(IOperatorContext)
Initializes the operators in the subscription by setting the specified operator context and starting the operators.
Declaration
public void Initialize(IOperatorContext context)Parameters
| Type | Name | Description |
|---|---|---|
| IOperatorContext | context | Operator context to set on the operators in the subscription. |
Initialize(IOperatorContext, IOperatorStateReaderFactory)
Initializes the operators in the subscription using the specified operator context, optionally applying state to them.
Declaration
public void Initialize(IOperatorContext context, IOperatorStateReaderFactory state)Parameters
| Type | Name | Description |
|---|---|---|
| IOperatorContext | context | Operator context to set on the operators in the subscription. |
| IOperatorStateReaderFactory | state | State reader factory to read operator state from. This parameter can be left |
Initialize(ISubscription, IOperatorContext)
Initializes the operators in the subscription by setting the specified operator context and starting the operators.
Declaration
public static void Initialize(ISubscription subscription, IOperatorContext context)Parameters
| Type | Name | Description |
|---|---|---|
| ISubscription | subscription | The subscription to initialize and start. |
| IOperatorContext | context | Operator context to set on the operators in the subscription. |
LoadState(IOperatorStateReaderFactory)
Loads the state of operators in the subscription using the specified operator state reader facotry.
Declaration
public void LoadState(IOperatorStateReaderFactory factory)Parameters
| Type | Name | Description |
|---|---|---|
| IOperatorStateReaderFactory | factory | State reader factory to read operator state from. |
SetContext(IOperatorContext)
Sets the specified operator context to operators in the subscription.
Declaration
public void SetContext(IOperatorContext context)Parameters
| Type | Name | Description |
|---|---|---|
| IOperatorContext | context | Operator context to set on the operators in the subscription. |
SetContext(ISubscription, IOperatorContext)
Sets the specified operator context to operators in the subscription.
Declaration
public static void SetContext(ISubscription subscription, IOperatorContext context)Parameters
| Type | Name | Description |
|---|---|---|
| ISubscription | subscription | The subscription to pass operator context to. |
| IOperatorContext | context | Operator context to set on the operators in the subscription. |
Start()
Starts the operators in the subscription.
Declaration
public void Start()Start(ISubscription)
Starts the operators in the subscription.
Declaration
public static void Start(ISubscription subscription)Parameters
| Type | Name | Description |
|---|---|---|
| ISubscription | subscription | The subscription to start. |
Subscribe()
Initializes the operators in the subscription by obtaining the inputs that constitute the operator tree.
Declaration
public void Subscribe()Subscribe(ISubscription)
Initializes the operators in the subscription by obtaining the inputs that constitute the operator tree.
Declaration
public static void Subscribe(ISubscription subscription)Parameters
| Type | Name | Description |
|---|---|---|
| ISubscription | subscription | The subscription to initialize. |