concurrent

fun <T : Any> Sinks.Many<T>.concurrent(): ConcurrentManySink<T>