korge-core/korlibs.io.async/AsyncSignal

AsyncSignal

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

Constructors

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

Properties

val hasListeners: Boolean

val listenerCount: Int

val onRegister: () -> Unit

Functions

fun add(handler: suspend (T) -> Unit): Closeable

fun clear()

suspend operator fun invoke(value: T)

operator fun invoke(handler: suspend (T) -> Unit): Closeable

suspend operator fun AsyncSignal<Unit>.invoke()

suspend fun listen(): ReceiveChannel<T>

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

fun once(handler: suspend (T) -> Unit): Closeable

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

open suspend override fun waitOneBase(): T