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.

The SubscriptionOptions configured for the subscription.

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 launchIn(scope: CoroutineScope): Job

Launches the actor.