reactor-kotlin-extensions

reactor.kotlin.adapter.rxjava

toCompletable()

toFlowable()

toFlux()

toMaybe()

toMono()

toObservable()

toSingle()

reactor.kotlin.core.publisher

cast()

collectMap()

doOnError()

ofType()

onErrorMap()

onErrorResume()

onErrorReturn()

split()

switchIfEmpty()

switchIfEmptyDeferred()

toFlux()

toMono()

whenComplete()

zip()

reactor.kotlin.core.util.function

component1()

component2()

component3()

component4()

component5()

component6()

component7()

component8()

reactor.kotlin.extra.bool

logicalAnd()

logicalNAnd()

logicalNOr()

logicalOr()

logicalXOr()

not()

reactor.kotlin.extra.math

average()

averageAll()

averageAsBigDecimal()

averageAsBigInt()

averageAsDouble()

averageAsFloat()

max()

min()

sum()

sumAll()

sumAsBigDecimal()

sumAsBigInt()

sumAsDouble()

sumAsFloat()

sumAsInt()

sumAsLong()

sumDouble()

reactor.kotlin.extra.retry

repeatExponentialBackoff()

repeatRandomBackoff()

retryExponentialBackoff()

retryRandomBackoff()

reactor.kotlin.extra.swing

toScheduler()

reactor.kotlin.test

expectError()

hasDroppedErrorOfType()

hasOperatorErrorOfType()

test()

testUsingVirtualTime()

verifyError()