reactor-kotlin-extensions
Module Contents
alltypes
Module Contents
io.reactivex.Completable
io.reactivex.Flowable
io.reactivex.Maybe
io.reactivex.Observable
io.reactivex.Single
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.eclipse.swt.widgets.Display
org.reactivestreams.Publisher
reactor.core.publisher.Flux
reactor.core.publisher.Flux
reactor.core.publisher.Flux
reactor.core.publisher.Flux
Module Contents
fun <T> Flux<T>.repeatExponentialBackoff(: Long, : Duration, : Duration? = null, : Boolean = false, : ((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(: Long, : Duration, : Duration? = null, : Boolean = false, : ((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
reactor.core.publisher.Mono
reactor.core.publisher.Mono
Module Contents
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 <E : Throwable, T> Mono<T>.onErrorMap(type: KClass<E>, predicate: (E) -> Boolean, 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
reactor.core.publisher.Mono
Module Contents
fun <T> Mono<T>.repeatExponentialBackoff(: Long, : Duration, : Duration? = null, : Boolean = false, : ((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(: Long, : Duration, : Duration? = null, : Boolean = false, : ((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
reactor.test.StepVerifier.Assertions
reactor.test.StepVerifier.LastStep
reactor.util.function.Tuple2
reactor.util.function.Tuple3
reactor.util.function.Tuple4
reactor.util.function.Tuple5
reactor.util.function.Tuple6
reactor.util.function.Tuple7
reactor.util.function.Tuple8
package reactor.kotlin.adapter.rxjava
package reactor.kotlin.core.publisher
Module Contents
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
Module Contents
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 <E : Throwable, T> Mono<T>.onErrorMap(type: KClass<E>, predicate: (E) -> Boolean, 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
package reactor.kotlin.extra.bool
package reactor.kotlin.extra.math
package reactor.kotlin.extra.retry
Module Contents
reactor.core.publisher.Flux
Module Contents
fun <T> Flux<T>.repeatExponentialBackoff(: Long, : Duration, : Duration? = null, : Boolean = false, : ((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(: Long, : Duration, : Duration? = null, : Boolean = false, : ((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
Module Contents
fun <T> Mono<T>.repeatExponentialBackoff(: Long, : Duration, : Duration? = null, : Boolean = false, : ((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(: Long, : Duration, : Duration? = null, : Boolean = false, : ((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
package reactor.kotlin.test