reactor.core.publisher - reactor-core

reactor-core / reactor.core.publisher

Package reactor.core.publisher

Extensions for External Classes

java.util.concurrent.Callable
java.util.concurrent.CompletableFuture
java.util.stream.Stream
kotlin.Array
kotlin.BooleanArray
kotlin.ByteArray
kotlin.DoubleArray
kotlin.FloatArray
kotlin.Function0
kotlin.IntArray
kotlin.LongArray
kotlin.ShortArray
kotlin.Throwable
kotlin.collections.Iterable
kotlin.collections.Iterator
kotlin.sequences.Sequence
org.reactivestreams.Publisher

Functions

cast	`fun <T : Any> Flux<>.cast(): Flux<T>` Extension for Flux.cast providing a `cast<Foo>()` variant. `fun <T : Any> Mono<>.cast(): Mono<T>` Extension for Mono.cast providing a `cast<Foo>()` variant.
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. `fun <T, E : Throwable> Mono<T>.doOnError(exceptionType: KClass<E>, onError: (E) -> Unit): Mono<T>` Extension for Mono.doOnError providing a KClass based variant.
ofType	`fun <T : Any> Flux<>.ofType(): Flux<T>` Extension for Flux.ofType providing a `ofType<Foo>()` variant. `fun <T : Any> Mono<>.ofType(): Mono<T>` Extension for Mono.ofType providing a `ofType<Foo>()` variant.
onErrorMap	`fun <T, E : Throwable> Flux<T>.onErrorMap(exceptionType: KClass<E>, mapper: (E) -> Throwable): Flux<T>` Extension for Flux.onErrorMap providing a KClass based variant. `fun <T, E : Throwable> Mono<T>.onErrorMap(exceptionType: KClass<E>, mapper: (E) -> Throwable): Mono<T>` Extension for Mono.onErrorMap providing a KClass based variant.
onErrorResume	`fun <T : Any, E : Throwable> Flux<T>.onErrorResume(exceptionType: KClass<E>, fallback: (E) -> Publisher<T>): Flux<T>` Extension for Flux.onErrorResume providing a KClass based variant. `fun <T : Any, E : Throwable> Mono<T>.onErrorResume(exceptionType: KClass<E>, fallback: (E) -> Mono<T>): Mono<T>` Extension for Mono.onErrorResume providing a KClass based variant.
onErrorReturn	`fun <T : Any, E : Throwable> Flux<T>.onErrorReturn(exceptionType: KClass<E>, value: T): Flux<T>` Extension for Flux.onErrorReturn providing a KClass based variant. `fun <T : Any, E : Throwable> Mono<T>.onErrorReturn(exceptionType: KClass<E>, value: T): Mono<T>` Extension for Mono.onErrorReturn providing a KClass based variant.
split	`fun <T : Any> Flux<out Iterable<T>>.split(): Flux<T>` Extension for flattening Flux of Iterable
toMono	`fun <T : Any> T.toMono(): Mono<T>` Extension for transforming an object to a Mono.
whenComplete	`fun whenComplete(vararg sources: Publisher<Void>): Mono<Void>` Aggregates the given void Publishers into a new void Mono. An alias for a corresponding Mono.when to avoid use of `when`, which is a keyword in Kotlin.
zip	`fun <R> zip(vararg monos: Mono<>, combinator: (Array<>) -> R): Mono<R>` Aggregates the given Monos into a new Mono.