korge-core/korlibs.io.async/Signal

Signal

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

Constructors

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

Properties

val hasListeners: Boolean

val listenerCount: Int

val onRegister: () -> Unit

Functions

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

fun Signal<Unit>.addCallInit(handler: (Unit) -> Unit): Closeable

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

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

fun <T> Signal<T>.addSuspend(context: CoroutineContext, handler: suspend (T) -> Unit): Closeable

fun clear()

executeAndWaitSignal

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

operator fun invoke(value: T)

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

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): Closeable

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

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

fun <T> Signal<T>.waitOneAsync(): Deferred<T>

open suspend override fun waitOneBase(): T

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