Signal

class Signal<T>(onRegister: () -> Unit = {}) : BaseSignal<T, (T) -> Unit>

Constructors

constructor(onRegister: () -> Unit = {})

fun add(handler: (T) -> Unit): AutoCloseable

fun <T> Signal<T>.addCallInit(initial: T, handler: (T) -> Unit): AutoCloseable

suspend fun <T> Signal<T>.addSuspend(handler: suspend (T) -> Unit): AutoCloseable

fun clear()

inline suspend fun <T> Signal<T>.executeAndWaitSignal(callback: () -> Unit): T

operator fun invoke(value: T)

operator fun invoke(handler: (T) -> Unit): AutoCloseable

operator fun Signal<Unit>.invoke()

suspend fun listen(): ReceiveChannel<T>

fun <TI, TO> Signal<TI>.mapSignal(transform: (TI) -> TO): Signal<TO>

fun once(handler: (T) -> Unit): AutoCloseable

suspend fun <T> Signal<T>.waitOne(): T

suspend fun <T> Signal<T>.waitOne(timeout: Duration): T?

open suspend override fun waitOneBase(): T

suspend fun <T> Signal<T>.waitOneOpt(timeout: Duration?): T?