cast |
Extension for Flux.cast providing a 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 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>. |
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> |