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

publish1

suspend fun publish1(a: A): Unit

Publishes one A to topic.

This waits until a is published to all subscribers. If any of the subscribers is over the maxQueued limit, this will wait to complete until that subscriber processes enough of its elements such that a is enqueued.