asPublisher

fun <T> asPublisher(context: CoroutineContext? = null, block: suspend () -> T): Publisher<T & Any>(source)

block 包装为 org.reactivestreams.Publisher.