SubscriptionCommands

Types

Link copied to clipboard
class Receive<T>(key: SubscriptionKey<T>, result: Result<T>, revision: String, marker: Marker = Marker.None) : SubscriptionCommand<T>

Handles the result received from the subscription source.

Link copied to clipboard
class Reset<T>(key: SubscriptionKey<T>, revision: String) : SubscriptionCommand<T>

Resets the state and re-executes the subscription process.

Link copied to clipboard
class Restart<T>(key: SubscriptionKey<T>, revision: String, restartedAt: Long) : SubscriptionCommand<T>