Subscription

Subscription as the base interface for an SubscriptionClient implementations.

Type of the receive value from the subscription.

Properties

abstract val command: SendChannel<SubscriptionCommand<T>>

Send Channel to manipulate the state of the subscription.

abstract val event: SharedFlow<SubscriptionEvent>

Shared Flow to receive subscription events.

abstract val source: SharedFlow<Result<T>>

Shared Flow to receive subscription result.

abstract val state: StateFlow<SubscriptionState<T>>

State Flow to receive the current state of the subscription.

abstract fun attach(iid: InstanceId)

Attaches an instance to the actor.

abstract fun detach(iid: InstanceId)

Detaches an instance from the actor.

Returns whether the actor has attached instances.