reactor-kotlin-extensions/reactor.kotlin.test

Package reactor.kotlin.test

Functions

inline fun <T : Throwable> StepVerifier.LastStep.expectError(): StepVerifier

Extension for StepVerifier.LastStep.expectError providing a expectError<Foo>() variant.

fun StepVerifier.LastStep.expectError(kClass: KClass<out Throwable>): StepVerifier

Extension for StepVerifier.LastStep.expectError providing a KClass based variant.

hasDroppedErrorOfType

inline fun <T : Throwable> StepVerifier.Assertions.hasDroppedErrorOfType(): StepVerifier.Assertions

Extension for StepVerifier.Assertions.hasDroppedErrorOfType providing a hasDroppedErrorOfType<Foo>() variant.

fun StepVerifier.Assertions.hasDroppedErrorOfType(kClass: KClass<out Throwable>): StepVerifier.Assertions

Extension for StepVerifier.Assertions.hasDroppedErrorOfType providing a KClass based variant.

hasOperatorErrorOfType

inline fun <T : Throwable> StepVerifier.Assertions.hasOperatorErrorOfType(): StepVerifier.Assertions

Extension for StepVerifier.Assertions.hasOperatorErrorOfType providing a hasOperatorErrorOfType<Foo>() variant.

fun StepVerifier.Assertions.hasOperatorErrorOfType(kClass: KClass<out Throwable>): StepVerifier.Assertions

Extension for StepVerifier.Assertions.hasOperatorErrorOfType providing a KClass based variant.

fun <T> Flux<T>.test(): StepVerifier.FirstStep<T>

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

fun <T> Flux<T>.test(options: StepVerifierOptions): StepVerifier.FirstStep<T>

Extension for testing Flux with StepVerifier API.

fun <T> Mono<T>.test(): StepVerifier.FirstStep<T>

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

fun <T> Mono<T>.test(options: StepVerifierOptions): StepVerifier.FirstStep<T>

Extension for testing Mono with StepVerifier API.

testUsingVirtualTime

fun <T> () -> Publisher<T>.testUsingVirtualTime(): StepVerifier.FirstStep<T>

fun <T> () -> Publisher<T>.testUsingVirtualTime(n: Long): StepVerifier.FirstStep<T>

Extension for testing the supplied Publisher with StepVerifier API, using a VirtualTimeScheduler.

fun <T> Publisher<T>.testUsingVirtualTime(options: StepVerifierOptions): StepVerifier.FirstStep<T>

fun <T> Publisher<T>.testUsingVirtualTime(vtsLookup: () -> VirtualTimeScheduler, n: Long): StepVerifier.FirstStep<T>

Extension for testing a Publisher with StepVerifier API, using a VirtualTimeScheduler.

inline fun <T : Throwable> StepVerifier.LastStep.verifyError(): Duration

Extension for StepVerifier.LastStep.verifyError providing a verifyError<Foo>() variant.

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

Extension for StepVerifier.LastStep.verifyError providing a KClass based variant.