core/pro.respawn.flowmvi.util

Package-level declarations

Properties

val MainCoroutineDispatcher.immediateOrDefault: MainCoroutineDispatcher

Obtain a MainCoroutineDispatcher.immediate, and if not supported by the current platform, fall back to a default MainCoroutineDispatcher.

inline fun <T> Flow<T>.catchExceptions(crossinline block: suspend FlowCollector<T>.(Exception) -> Unit): Flow<T>

Catches exceptions only, rethrowing any throwables

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.

inline fun <T> Any?.typed(): T?

Cast this to type T or return null.

inline fun <T : R, R> R.withType(block: T.() -> R): R

Do the operation on this if the type of this is T, and return R, otherwise return this