ManagedSubscription

Properties

Link copied to clipboard
open override val command: SendChannel<SubscriptionCommand<T>>

Send Channel to manipulate the state of the subscription.

Link copied to clipboard
open override val event: MutableSharedFlow<SubscriptionEvent>

Shared Flow to receive subscription events.

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override val source: SharedFlow<Result<T>>

Shared Flow to receive subscription result.

Link copied to clipboard
open override val state: StateFlow<SubscriptionState<T>>

State Flow to receive the current state of the subscription.

Functions

Link copied to clipboard
open override fun attach(iid: InstanceId)

Attaches an instance to the actor.

Link copied to clipboard
fun cancel()
Link copied to clipboard
open override fun detach(iid: InstanceId)

Detaches an instance from the actor.

Link copied to clipboard
fun forceUpdate(data: T)
Link copied to clipboard
open override fun hasAttachedInstances(): Boolean

Returns whether the actor has attached instances.

Link copied to clipboard
fun isCacheable(reply: Reply<T>): Boolean
Link copied to clipboard
fun resume()