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

onErrorMap

fun <T, E : Throwable> Flux<T>.onErrorMap(exceptionType: KClass<E>, mapper: (E) -> Throwable): Flux<T>
Content copied to clipboard

Extension for Flux.onErrorMap providing a KClass based variant.

Author

Sebastien Deleuze

Since

3.1


fun <T, E : Throwable> Mono<T>.onErrorMap(exceptionType: KClass<E>, mapper: (E) -> Throwable): Mono<T>
Content copied to clipboard

Extension for Mono.onErrorMap providing a KClass based variant.

Author

Sebastien Deleuze

Since

3.1


fun <E : Throwable, T> Mono<T>.onErrorMap(    type: KClass<E>,     predicate: (E) -> Boolean,     mapper: (E) -> Throwable): Mono<T>
Content copied to clipboard

Extension for Mono.onErrorMap providing a KClass based variant and predicate.

Author

Nikesh Shetty

Since

3.3.1