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

Extensions for reactor.core.publisher.Flux

cast

Extension for Flux.cast providing a cast<Foo>() variant.

fun <T : Any> Flux<*>.cast(): Flux<T>

doOnError

Extension for Flux.doOnError providing a KClass based variant.

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

ofType

Extension for Flux.ofType providing a ofType<Foo>() variant.

fun <T : Any> Flux<*>.ofType(): Flux<T>

onErrorMap

Extension for Flux.onErrorMap providing a KClass based variant.

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

onErrorResume

Extension for Flux.onErrorResume providing a KClass based variant.

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

onErrorReturn

Extension for Flux.onErrorReturn providing a KClass based variant.

fun <T : Any, E : Throwable> Flux<T>.onErrorReturn(exceptionType: KClass<E>, value: T): Flux<T>

split

Extension for flattening Flux of Iterable

fun <T : Any> Flux<out Iterable<T>>.split(): Flux<T>

switchIfEmpty

Extension for Flux.switchIfEmpty accepting a function providing a Publisher. This allows having a deferred execution with the switchIfEmpty operator

fun <T> Flux<T>.switchIfEmpty(s: () -> Publisher<T>): Flux<T>

switchIfEmptyDeferred

Extension for Flux.switchIfEmpty accepting a function providing a Publisher. This allows having a deferred execution with the switchIfEmpty operator

fun <T> Flux<T>.switchIfEmptyDeferred(s: () -> Publisher<T>): Flux<T>