korge-core/korlibs.io.async/waitSubscriberCloseable

waitSubscriberCloseable

suspend fun <T> waitSubscriberCloseable(block: ((T) -> Unit) -> Closeable): T