korge-core/korlibs.io.async/BaseSignal2

BaseSignal2

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

Inheritors

Constructors

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

Types

inner class Node(val once: Boolean, val item: (T1, T2) -> Unit) : Closeable

Properties

val listenerCount: Int

val onRegister: () -> Unit

Functions

fun clear()

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

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