korge-core/korlibs.io.async/Signal2

Signal2

class Signal2<T1, T2>(onRegister: () -> Unit = {}) : BaseSignal2<T1, T2>

Constructors

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

Properties

val listenerCount: Int

val onRegister: () -> Unit

Functions

fun add(handler: (T1, T2) -> Unit): Closeable

fun clear()

operator fun invoke(handler: (T1, T2) -> Unit): Closeable

operator fun invoke(value1: T1, value2: T2)

suspend fun listen(): ReceiveChannel<Pair<T1, T2>>

fun once(handler: (T1, T2) -> Unit): Closeable

suspend fun <T1, T2> Signal2<T1, T2>.waitOne(): Pair<T1, T2>

open suspend override fun waitOneBase(): Pair<T1, T2>