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

onErrorResume

fun <T : Any, E : Throwable> Flux<T>.onErrorResume(exceptionType: KClass<E>, fallback: (E) -> Publisher<T>): Flux<T>
Content copied to clipboard

Extension for Flux.onErrorResume providing a KClass based variant.

Author

Sebastien Deleuze

Since

3.1


fun <T : Any, E : Throwable> Mono<T>.onErrorResume(exceptionType: KClass<E>, fallback: (E) -> Mono<T>): Mono<T>
Content copied to clipboard

Extension for Mono.onErrorResume providing a KClass based variant.

Author

Sebastien Deleuze

Since

3.1