reactor-kotlin-extensions

alltypes

io.reactivex.Completable

fun Completable.toMono(): Mono<Void>

io.reactivex.Flowable

fun <T> Flowable<T>.toFlux(): Flux<T>

io.reactivex.Maybe

fun <T> Maybe<T>.toMono(): Mono<T>

io.reactivex.Observable

fun <T> Observable<T>.toFlux(strategy: BackpressureStrategy = BackpressureStrategy.BUFFER): Flux<T>

io.reactivex.Single

fun <T> Single<T>.toMono(): Mono<T>

java.util.concurrent.Callable

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

java.util.concurrent.CompletableFuture

fun <T> CompletableFuture<out T?>.toMono(): Mono<T>

java.util.stream.Stream

fun <T : Any> Stream<T>.toFlux(): Flux<T>

kotlin.Array

fun <T> Array<out T>.toFlux(): Flux<T>

kotlin.BooleanArray

fun BooleanArray.toFlux(): Flux<Boolean>

kotlin.ByteArray

fun ByteArray.toFlux(): Flux<Byte>

kotlin.collections.Iterable

fun <T : Any> Iterable<T>.toFlux(): Flux<T>
fun Iterable<Publisher<*>>.whenComplete(): Mono<Void>
inline fun <T, R> Iterable<Mono<T>>.zip(crossinline combinator: (List<T>) -> R): Mono<R>

kotlin.collections.Iterator

fun <T : Any> Iterator<T>.toFlux(): Flux<T>

kotlin.DoubleArray

fun DoubleArray.toFlux(): Flux<Double>

kotlin.FloatArray

fun FloatArray.toFlux(): Flux<Float>

kotlin.Function0

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

kotlin.IntArray

fun IntArray.toFlux(): Flux<Int>

kotlin.LongArray

fun LongArray.toFlux(): Flux<Long>

kotlin.sequences.Sequence

fun <T : Any> Sequence<T>.toFlux(): Flux<T>

kotlin.ShortArray

fun ShortArray.toFlux(): Flux<Short>

kotlin.Throwable

fun <T> Throwable.toFlux(): Flux<T>
fun <T> Throwable.toMono(): Mono<T>

org.eclipse.swt.widgets.Display

fun Display.toScheduler(): Scheduler

org.reactivestreams.Publisher

fun <T : Any> Publisher<T>.toFlux(): Flux<T>
fun <T> Publisher<T>.toMono(): Mono<T>

reactor.core.publisher.Flux

fun <T> Flux<T>.toFlowable(): Flowable<T>
fun <T> Flux<T>.toObservable(): Observable<T>

reactor.core.publisher.Flux

fun <reified T : Any> Flux<*>.cast(): Flux<T>
fun <T, E : Throwable> Flux<T>.doOnError(exceptionType: KClass<E>, onError: (E) -> Unit): Flux<T>
fun <reified T : Any> Flux<*>.ofType(): Flux<T>
fun <T, E : Throwable> Flux<T>.onErrorMap(exceptionType: KClass<E>, mapper: (E) -> Throwable): Flux<T>
fun <T : Any, E : Throwable> Flux<T>.onErrorResume(exceptionType: KClass<E>, fallback: (E) -> Publisher<T>): Flux<T>
fun <T : Any, E : Throwable> Flux<T>.onErrorReturn(exceptionType: KClass<E>, value: T): Flux<T>
fun <T : Any> Flux<out Iterable<T>>.split(): Flux<T>
fun <T> Flux<T>.switchIfEmpty(s: () -> Publisher<T>): Flux<T>

reactor.core.publisher.Flux

fun <T : Number> Flux<T>.average(): Mono<Double>
fun <T> Flux<T>.average(mapper: (T) -> Number): Mono<Double>
fun <T : Comparable<T>> Flux<T>.max(): Mono<T>
fun <T> Flux<T>.max(comp: Comparator<T>): Mono<T>
fun <T> Flux<T>.max(comp: (T, T) -> Int): Mono<T>
fun <T : Comparable<T>> Flux<T>.min(): Mono<T>
fun <T> Flux<T>.min(comp: Comparator<T>): Mono<T>
fun <T> Flux<T>.min(comp: (T, T) -> Int): Mono<T>
fun <T : Number> Flux<T>.sum(): Mono<Long>
fun <T> Flux<T>.sum(mapper: (T) -> Number): Mono<Long>
fun <T : Number> Flux<T>.sumDouble(): Mono<Double>
fun <T> Flux<T>.sumDouble(mapper: (T) -> Number): Mono<Double>

reactor.core.publisher.Flux

fun <T> Flux<T>.repeatExponentialBackoff(times: Long, first: Duration, max: Duration? = null, jitter: Boolean = false, doOnRepeat: ((RepeatContext<T>) -> Unit)? = null): Flux<T>
fun <T> Flux<T>.repeatRandomBackoff(times: Long, first: Duration, max: Duration? = null, doOnRepeat: ((RepeatContext<T>) -> Unit)? = null): Flux<T>
fun <T> Flux<T>.retryExponentialBackoff(times: Long, first: Duration, max: Duration? = null, jitter: Boolean = false, doOnRetry: ((RetryContext<T>) -> Unit)? = null): Flux<T>
fun <T> Flux<T>.retryRandomBackoff(times: Long, first: Duration, max: Duration? = null, doOnRetry: ((RetryContext<T>) -> Unit)? = null): Flux<T>

reactor.core.publisher.Flux

fun <T> Flux<T>.test(): FirstStep<T>
fun <T> Flux<T>.test(n: Long): FirstStep<T>

reactor.core.publisher.Mono

fun Mono<*>.toCompletable(): Completable
fun <T> Mono<T>.toFlowable(): Flowable<T>
fun <T> Mono<T>.toMaybe(): Maybe<T>
fun <T> Mono<T>.toSingle(): Single<T>

reactor.core.publisher.Mono

fun <reified T : Any> Mono<*>.cast(): Mono<T>
fun <T, E : Throwable> Mono<T>.doOnError(exceptionType: KClass<E>, onError: (E) -> Unit): Mono<T>
fun <reified T : Any> Mono<*>.ofType(): Mono<T>
fun <T, E : Throwable> Mono<T>.onErrorMap(exceptionType: KClass<E>, mapper: (E) -> Throwable): Mono<T>
fun <T : Any, E : Throwable> Mono<T>.onErrorResume(exceptionType: KClass<E>, fallback: (E) -> Mono<T>): Mono<T>
fun <T : Any, E : Throwable> Mono<T>.onErrorReturn(exceptionType: KClass<E>, value: T): Mono<T>
fun <T> Mono<T>.switchIfEmpty(s: () -> Mono<T>): Mono<T>

reactor.core.publisher.Mono

fun Mono<Boolean>.logicalAnd(rightHand: Mono<Boolean>): Mono<Boolean>
fun Mono<Boolean>.logicalNAnd(rightHand: Mono<Boolean>): Mono<Boolean>
fun Mono<Boolean>.logicalNOr(rightHand: Mono<Boolean>): Mono<Boolean>
fun Mono<Boolean>.logicalOr(rightHand: Mono<Boolean>): Mono<Boolean>
fun Mono<Boolean>.logicalXOr(rightHand: Mono<Boolean>): Mono<Boolean>
operator fun Mono<Boolean>.not(): Mono<Boolean>

reactor.core.publisher.Mono

fun <T> Mono<T>.repeatExponentialBackoff(times: Long, first: Duration, max: Duration? = null, jitter: Boolean = false, doOnRepeat: ((RepeatContext<T>) -> Unit)? = null): Flux<T>
fun <T> Mono<T>.repeatRandomBackoff(times: Long, first: Duration, max: Duration? = null, doOnRepeat: ((RepeatContext<T>) -> Unit)? = null): Flux<T>
fun <T> Mono<T>.retryExponentialBackoff(times: Long, first: Duration, max: Duration? = null, jitter: Boolean = false, doOnRetry: ((RetryContext<T>) -> Unit)? = null): Mono<T>
fun <T> Mono<T>.retryRandomBackoff(times: Long, first: Duration, max: Duration? = null, doOnRetry: ((RetryContext<T>) -> Unit)? = null): Mono<T>

reactor.core.publisher.Mono

fun <T> Mono<T>.test(): FirstStep<T>
fun <T> Mono<T>.test(n: Long): FirstStep<T>

reactor.test.StepVerifier.Assertions

fun Assertions.hasDroppedErrorOfType(kClass: KClass<out Throwable>): Assertions
fun <reified T : Throwable> Assertions.hasDroppedErrorOfType(): Assertions
fun Assertions.hasOperatorErrorOfType(kClass: KClass<out Throwable>): Assertions
fun <reified T : Throwable> Assertions.hasOperatorErrorOfType(): Assertions

reactor.test.StepVerifier.LastStep

fun LastStep.expectError(kClass: KClass<out Throwable>): StepVerifier
fun <reified T : Throwable> LastStep.expectError(): StepVerifier
fun LastStep.verifyError(kClass: KClass<out Throwable>): Duration
fun <reified T : Throwable> LastStep.verifyError(): Duration

reactor.util.function.Tuple2

operator fun <T> Tuple2<T, *>.component1(): T
operator fun <T> Tuple2<*, T>.component2(): T

reactor.util.function.Tuple3

operator fun <T> Tuple3<*, *, T>.component3(): T

reactor.util.function.Tuple4

operator fun <T> Tuple4<*, *, *, T>.component4(): T

reactor.util.function.Tuple5

operator fun <T> Tuple5<*, *, *, *, T>.component5(): T

reactor.util.function.Tuple6

operator fun <T> Tuple6<*, *, *, *, *, T>.component6(): T

reactor.util.function.Tuple7

operator fun <T> Tuple7<*, *, *, *, *, *, T>.component7(): T

reactor.util.function.Tuple8

operator fun <T> Tuple8<*, *, *, *, *, *, *, T>.component8(): T

package reactor.kotlin.adapter.rxjava

io.reactivex.Completable

fun Completable.toMono(): Mono<Void>

io.reactivex.Flowable

fun <T> Flowable<T>.toFlux(): Flux<T>

io.reactivex.Maybe

fun <T> Maybe<T>.toMono(): Mono<T>

io.reactivex.Observable

fun <T> Observable<T>.toFlux(strategy: BackpressureStrategy = BackpressureStrategy.BUFFER): Flux<T>

io.reactivex.Single

fun <T> Single<T>.toMono(): Mono<T>

reactor.core.publisher.Flux

fun <T> Flux<T>.toFlowable(): Flowable<T>
fun <T> Flux<T>.toObservable(): Observable<T>

reactor.core.publisher.Mono

fun Mono<*>.toCompletable(): Completable
fun <T> Mono<T>.toFlowable(): Flowable<T>
fun <T> Mono<T>.toMaybe(): Maybe<T>
fun <T> Mono<T>.toSingle(): Single<T>

package reactor.kotlin.core.publisher

java.util.concurrent.Callable

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

java.util.concurrent.CompletableFuture

fun <T> CompletableFuture<out T?>.toMono(): Mono<T>

java.util.stream.Stream

fun <T : Any> Stream<T>.toFlux(): Flux<T>

kotlin.Array

fun <T> Array<out T>.toFlux(): Flux<T>

kotlin.BooleanArray

fun BooleanArray.toFlux(): Flux<Boolean>

kotlin.ByteArray

fun ByteArray.toFlux(): Flux<Byte>

kotlin.collections.Iterable

fun <T : Any> Iterable<T>.toFlux(): Flux<T>
fun Iterable<Publisher<*>>.whenComplete(): Mono<Void>
inline fun <T, R> Iterable<Mono<T>>.zip(crossinline combinator: (List<T>) -> R): Mono<R>

kotlin.collections.Iterator

fun <T : Any> Iterator<T>.toFlux(): Flux<T>

kotlin.DoubleArray

fun DoubleArray.toFlux(): Flux<Double>

kotlin.FloatArray

fun FloatArray.toFlux(): Flux<Float>

kotlin.Function0

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

kotlin.IntArray

fun IntArray.toFlux(): Flux<Int>

kotlin.LongArray

fun LongArray.toFlux(): Flux<Long>

kotlin.sequences.Sequence

fun <T : Any> Sequence<T>.toFlux(): Flux<T>

kotlin.ShortArray

fun ShortArray.toFlux(): Flux<Short>

kotlin.Throwable

fun <T> Throwable.toFlux(): Flux<T>
fun <T> Throwable.toMono(): Mono<T>

org.reactivestreams.Publisher

fun <T : Any> Publisher<T>.toFlux(): Flux<T>
fun <T> Publisher<T>.toMono(): Mono<T>

reactor.core.publisher.Flux

fun <reified T : Any> Flux<*>.cast(): Flux<T>
fun <T, E : Throwable> Flux<T>.doOnError(exceptionType: KClass<E>, onError: (E) -> Unit): Flux<T>
fun <reified T : Any> Flux<*>.ofType(): Flux<T>
fun <T, E : Throwable> Flux<T>.onErrorMap(exceptionType: KClass<E>, mapper: (E) -> Throwable): Flux<T>
fun <T : Any, E : Throwable> Flux<T>.onErrorResume(exceptionType: KClass<E>, fallback: (E) -> Publisher<T>): Flux<T>
fun <T : Any, E : Throwable> Flux<T>.onErrorReturn(exceptionType: KClass<E>, value: T): Flux<T>
fun <T : Any> Flux<out Iterable<T>>.split(): Flux<T>
fun <T> Flux<T>.switchIfEmpty(s: () -> Publisher<T>): Flux<T>

reactor.core.publisher.Mono

fun <reified T : Any> Mono<*>.cast(): Mono<T>
fun <T, E : Throwable> Mono<T>.doOnError(exceptionType: KClass<E>, onError: (E) -> Unit): Mono<T>
fun <reified T : Any> Mono<*>.ofType(): Mono<T>
fun <T, E : Throwable> Mono<T>.onErrorMap(exceptionType: KClass<E>, mapper: (E) -> Throwable): Mono<T>
fun <T : Any, E : Throwable> Mono<T>.onErrorResume(exceptionType: KClass<E>, fallback: (E) -> Mono<T>): Mono<T>
fun <T : Any, E : Throwable> Mono<T>.onErrorReturn(exceptionType: KClass<E>, value: T): Mono<T>
fun <T> Mono<T>.switchIfEmpty(s: () -> Mono<T>): Mono<T>

fun <T : Any> T.toMono(): Mono<T>
fun whenComplete(vararg sources: Publisher<*>): Mono<Void>
fun <R> zip(vararg monos: Mono<*>, combinator: (Array<*>) -> R): Mono<R>

package reactor.kotlin.core.util.function

reactor.util.function.Tuple2

operator fun <T> Tuple2<T, *>.component1(): T
operator fun <T> Tuple2<*, T>.component2(): T

reactor.util.function.Tuple3

operator fun <T> Tuple3<*, *, T>.component3(): T

reactor.util.function.Tuple4

operator fun <T> Tuple4<*, *, *, T>.component4(): T

reactor.util.function.Tuple5

operator fun <T> Tuple5<*, *, *, *, T>.component5(): T

reactor.util.function.Tuple6

operator fun <T> Tuple6<*, *, *, *, *, T>.component6(): T

reactor.util.function.Tuple7

operator fun <T> Tuple7<*, *, *, *, *, *, T>.component7(): T

reactor.util.function.Tuple8

operator fun <T> Tuple8<*, *, *, *, *, *, *, T>.component8(): T

package reactor.kotlin.extra.bool

reactor.core.publisher.Mono

fun Mono<Boolean>.logicalAnd(rightHand: Mono<Boolean>): Mono<Boolean>
fun Mono<Boolean>.logicalNAnd(rightHand: Mono<Boolean>): Mono<Boolean>
fun Mono<Boolean>.logicalNOr(rightHand: Mono<Boolean>): Mono<Boolean>
fun Mono<Boolean>.logicalOr(rightHand: Mono<Boolean>): Mono<Boolean>
fun Mono<Boolean>.logicalXOr(rightHand: Mono<Boolean>): Mono<Boolean>
operator fun Mono<Boolean>.not(): Mono<Boolean>

package reactor.kotlin.extra.math

reactor.core.publisher.Flux

fun <T : Number> Flux<T>.average(): Mono<Double>
fun <T> Flux<T>.average(mapper: (T) -> Number): Mono<Double>
fun <T : Comparable<T>> Flux<T>.max(): Mono<T>
fun <T> Flux<T>.max(comp: Comparator<T>): Mono<T>
fun <T> Flux<T>.max(comp: (T, T) -> Int): Mono<T>
fun <T : Comparable<T>> Flux<T>.min(): Mono<T>
fun <T> Flux<T>.min(comp: Comparator<T>): Mono<T>
fun <T> Flux<T>.min(comp: (T, T) -> Int): Mono<T>
fun <T : Number> Flux<T>.sum(): Mono<Long>
fun <T> Flux<T>.sum(mapper: (T) -> Number): Mono<Long>
fun <T : Number> Flux<T>.sumDouble(): Mono<Double>
fun <T> Flux<T>.sumDouble(mapper: (T) -> Number): Mono<Double>

package reactor.kotlin.extra.retry

reactor.core.publisher.Flux

fun <T> Flux<T>.repeatExponentialBackoff(times: Long, first: Duration, max: Duration? = null, jitter: Boolean = false, doOnRepeat: ((RepeatContext<T>) -> Unit)? = null): Flux<T>
fun <T> Flux<T>.repeatRandomBackoff(times: Long, first: Duration, max: Duration? = null, doOnRepeat: ((RepeatContext<T>) -> Unit)? = null): Flux<T>
fun <T> Flux<T>.retryExponentialBackoff(times: Long, first: Duration, max: Duration? = null, jitter: Boolean = false, doOnRetry: ((RetryContext<T>) -> Unit)? = null): Flux<T>
fun <T> Flux<T>.retryRandomBackoff(times: Long, first: Duration, max: Duration? = null, doOnRetry: ((RetryContext<T>) -> Unit)? = null): Flux<T>

reactor.core.publisher.Mono

fun <T> Mono<T>.repeatExponentialBackoff(times: Long, first: Duration, max: Duration? = null, jitter: Boolean = false, doOnRepeat: ((RepeatContext<T>) -> Unit)? = null): Flux<T>
fun <T> Mono<T>.repeatRandomBackoff(times: Long, first: Duration, max: Duration? = null, doOnRepeat: ((RepeatContext<T>) -> Unit)? = null): Flux<T>
fun <T> Mono<T>.retryExponentialBackoff(times: Long, first: Duration, max: Duration? = null, jitter: Boolean = false, doOnRetry: ((RetryContext<T>) -> Unit)? = null): Mono<T>
fun <T> Mono<T>.retryRandomBackoff(times: Long, first: Duration, max: Duration? = null, doOnRetry: ((RetryContext<T>) -> Unit)? = null): Mono<T>

package reactor.kotlin.extra.swing

org.eclipse.swt.widgets.Display

fun Display.toScheduler(): Scheduler

package reactor.kotlin.test

reactor.core.publisher.Flux

fun <T> Flux<T>.test(): FirstStep<T>
fun <T> Flux<T>.test(n: Long): FirstStep<T>

reactor.core.publisher.Mono

fun <T> Mono<T>.test(): FirstStep<T>
fun <T> Mono<T>.test(n: Long): FirstStep<T>

reactor.test.StepVerifier.Assertions

fun Assertions.hasDroppedErrorOfType(kClass: KClass<out Throwable>): Assertions
fun <reified T : Throwable> Assertions.hasDroppedErrorOfType(): Assertions
fun Assertions.hasOperatorErrorOfType(kClass: KClass<out Throwable>): Assertions
fun <reified T : Throwable> Assertions.hasOperatorErrorOfType(): Assertions

reactor.test.StepVerifier.LastStep

fun LastStep.expectError(kClass: KClass<out Throwable>): StepVerifier
fun <reified T : Throwable> LastStep.expectError(): StepVerifier
fun LastStep.verifyError(kClass: KClass<out Throwable>): Duration
fun <reified T : Throwable> LastStep.verifyError(): Duration