Commons/cz.acrobits.commons.observable

Package-level declarations

Types

CancellableProcessFlow

class CancellableProcessFlow<out I, O>

interface ~~MessageChannel~~

Scoped messaging channel for communicate between multiple subscribers.

class MutablePending<T> : Pending<T>

open class Pending<T>

Functions

emptyMutablePending

fun <T> emptyMutablePending(): MutablePending<T>

fun <T> emptyPending(): Pending<T>

mutablePendingOf

fun <T> mutablePendingOf(value: T): MutablePending<T>

fun <T> pendingOf(value: T): Pending<T>