waitSubscriber

suspend fun <T> waitSubscriber(block: ((T) -> Unit) -> Cancellable): T