reactor-kotlin-extensions / reactor.kotlin.core.publisher / kotlin.Throwable

Extensions for kotlin.Throwable

toFlux

Extension for transforming an exception to a Flux that completes with the specified error.

fun <T> Throwable.toFlux(): Flux<T>

toMono

Extension for transforming an exception to a Mono that completes with the specified error.

fun <T> Throwable.toMono(): Mono<T>