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.