kmongo / org.litote.kmongo.reactor / org.reactivestreams.Publisher

Extensions for org.reactivestreams.Publisher

block

Waits in a blocking fashion until the current Single signals a success value, null (which is returned) or an exception (which is propagated).

fun <T> Publisher<T>.block(): T?

blockLast

Subscribes to and awaits the termination of this Publisher instance in a blocking manner and rethrows any exception emitted.

fun Publisher<*>.blockLast(): Any?