reactor-test

alltypes

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>

package reactor.test

fun LastStep.expectError(kClass: KClass<out Throwable>): StepVerifier
inline fun <reified T : Throwable> LastStep.expectError(): StepVerifier
fun Assertions.hasDroppedErrorOfType(kClass: KClass<out Throwable>): Assertions
inline fun <reified T : Throwable> Assertions.hasDroppedErrorOfType(): Assertions
fun Assertions.hasOperatorErrorOfType(kClass: KClass<out Throwable>): Assertions
inline fun <reified T : Throwable> Assertions.hasOperatorErrorOfType(): Assertions
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>

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