arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Signal / discrete

discrete

abstract fun discrete(): Stream<A>

Returns a stream of the updates to this signal.

Updates that are very close together may result in only the last update appearing in the stream. If you want to be notified about every single update, use a Queue instead.