Class SubscriptionStateVisitor

Visitor to act on operator state of a subscription.

Inheritance

System.Object

SubscriptionStateVisitor

Namespace: Reaqtive

Assembly: Reaqtive.Core.dll

Syntax

public class SubscriptionStateVisitor : Object

Constructors

SubscriptionStateVisitor(ISubscription)

Creates a new subscription state visitor for the specified subscription.

Declaration

public SubscriptionStateVisitor(ISubscription subscription)

Parameters

Type	Name	Description
ISubscription	subscription	Subscription visited by this visitor.

Methods

HasStateChanged()

Determines whether the state of any of the operators in the subscription has changed.

Declaration

public bool HasStateChanged()

Returns

Type	Description
System.Boolean	true if any operator has state changes; otherwise, false.

HasStateChanged(ISubscription)

Determines whether the state of any of the operators in the subscription has changed.

Declaration

public static bool HasStateChanged(ISubscription subscription)

Parameters

Type	Name	Description
ISubscription	subscription	The subscription to check for state changes.

Returns

Type	Description
System.Boolean	true if any operator has state changes; otherwise, false.

LoadState(IOperatorStateReaderFactory)

Loads the state of operators in the subscription from state readers obtained by the specified state reader factory.

Declaration

public void LoadState(IOperatorStateReaderFactory factory)

Parameters

Type	Name	Description
IOperatorStateReaderFactory	factory	State reader factory to obtain state readers for operators from.

LoadState(ISubscription, IOperatorStateReaderFactory)

Loads the state of operators in the subscription from state readers obtained by the specified state reader factory.

Declaration

public static void LoadState(ISubscription subscription, IOperatorStateReaderFactory factory)

Parameters

Type	Name	Description
ISubscription	subscription	The subscription to save state for.
IOperatorStateReaderFactory	factory	State reader factory to obtain state readers for operators from.

OnStateSaved()

Propagates state save notifications to stateful operators in the subscription.

Declaration

public void OnStateSaved()

OnStateSaved(ISubscription)

Propagates state save notifications to stateful operators in the subscription.

Declaration

public static void OnStateSaved(ISubscription subscription)

Parameters

Type	Name	Description
ISubscription	subscription	The subscription to send state save notifications to.

SaveState(IOperatorStateWriterFactory)

Saves the state of operators in the subscription to state writers obtained by the specified state writer factory.

Declaration

public void SaveState(IOperatorStateWriterFactory factory)

Parameters

Type	Name	Description
IOperatorStateWriterFactory	factory	State writer factory to obtain state writers for operators from.

SaveState(ISubscription, IOperatorStateWriterFactory)

Saves the state of operators in the subscription to state writers obtained by the specified state writer factory.

Declaration

public static void SaveState(ISubscription subscription, IOperatorStateWriterFactory factory)

Parameters

Type	Name	Description
ISubscription	subscription	The subscription to save state for.
IOperatorStateWriterFactory	factory	State writer factory to obtain state writers for operators from.