Companion

object Companion

Functions

WhileSubscribed
Link copied to clipboard
fun WhileSubscribed(stopTimeoutMillis: Long = 0, replayExpirationMillis: Long = Long.MAX_VALUE): SharingStarted

Sharing is started when the first subscriber appears, immediately stops when the last subscriber disappears (by default), keeping the replay cache forever (by default).

Properties

Eagerly
Link copied to clipboard
val Eagerly: SharingStarted

Sharing is started immediately and never stops.

Lazily
Link copied to clipboard
val Lazily: SharingStarted

Sharing is started when the first subscriber appears and never stops.

Extensions

WhileSubscribed
Link copied to clipboard
fun SharingStarted.Companion.WhileSubscribed(stopTimeout: Duration = Duration.ZERO, replayExpiration: Duration = Duration.INFINITE): SharingStarted

Sharing is started when the first subscriber appears, immediately stops when the last subscriber disappears (by default), keeping the replay cache forever (by default).

Sources

common source
Link copied to clipboard