reactor-core / reactor.core.publisher / doOnError

doOnError

fun <T, E : Throwable> Flux<T>.doOnError(exceptionType: KClass<E>, onError: (E) -> Unit): Flux<T>

Extension for Flux.doOnError providing a KClass based variant.

Author
Sebastien Deleuze

Since
3.1

fun <T, E : Throwable> Mono<T>.doOnError(exceptionType: KClass<E>, onError: (E) -> Unit): Mono<T>

Extension for Mono.doOnError providing a KClass based variant.

Author
Sebastien Deleuze

Since
3.1