arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Topic / publish

publish

fun publish(): Pipe<A, Unit>

Publishes elements from source of A to this topic. Pipe equivalent of publish1.

Do you like Arrow?

Arrow Org
<