dstarcev
02/01/2018, 10:42 AMsuspend fun <T> Mono<T>.suspend(): T = suspendCancellableCoroutine { coroutine ->
doOnSuccess {
coroutine.tryResume(it)
}
doOnError {
coroutine.tryResumeWithException(it)
}
doOnCancel {
coroutine.cancel()
}
}