arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Topic / subscribeSize
subscribeSize
fun subscribeSize(maxQueued: Int): Stream<Pair<A, Int>>
Like subscribe but emits an approximate number of queued elements for this subscription
with each emitted A value.