arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Signal
Pure holder of a single value of type
A that can be read in the effect
||Returns a stream of the current value of the signal. An element is always available – on each pull, the current value is supplied.
abstract fun continuous():
||Returns a stream of the updates to this signal.
abstract fun discrete():
||Asynchronously gets the current value of this
abstract suspend fun get(): A
open fun <B> map(f: (A) -> B):
Companion Object Functions
||Pure holder of a single atomic value of type
A that can be both read and updated. Composes Signal and Atomic together to make an signalling atomic value.
class SignallingAtomic<A> :