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

Package reactor.kotlin.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.collections.Iterable

kotlin.collections.Iterator

kotlin.DoubleArray

kotlin.FloatArray

kotlin.Function0

kotlin.IntArray

kotlin.LongArray

kotlin.sequences.Sequence

kotlin.ShortArray

kotlin.Throwable

org.reactivestreams.Publisher

reactor.core.publisher.Flux

reactor.core.publisher.Mono

Functions

toMono

Extension for transforming a nullable object to a Mono.

fun <T : Any> T?.toMono(): Mono<T>

whenComplete

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.

fun whenComplete(vararg sources: Publisher<*>): Mono<Void>

zip

Aggregates the given Monos into a new Mono.

fun <R> zip(vararg monos: Mono<*>, combinator: (Array<*>) -> R): Mono<R>