arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Topic / publish
fun publish(): Pipe<A, Unit>
fun publish():
Pipe
<A,
Unit
>
Publishes elements from source of A to this topic. Pipe equivalent of publish1.
A
publish1
Do you like Arrow?