Extensions for kotlinx.coroutines.CoroutineScope

publish

fun <T> CoroutineScope.publish(
    context: CoroutineContext = EmptyCoroutineContext,
    block: suspend ProducerScope<T>.() -> Unit
): Publisher<T>