reactor-test / reactor.test / reactor.core.publisher.Flux

Extensions for reactor.core.publisher.Flux

test

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

Extension for testing Flux with StepVerifier API.