core/pro.respawn.flowmvi.api.context/SubscriptionAware

SubscriptionAware

interface SubscriptionAware

An entity that is aware of the number of its subscribers. Usually pro.respawn.flowmvi.api.PipelineContext

Inheritors

PipelineContext

Properties

subscriberCount

abstract val subscriberCount: StateFlow<Int>

The current number of subscribers of this entity.

Functions

doWhileSubscribed

inline suspend fun SubscriptionAware.doWhileSubscribed(stopDelay: Duration = 1.seconds, minSubscribers: Int = 1, crossinline action: suspend () -> Unit)

Runs action while this has at least minSubscribers subscribers. This function will suspend forever.