reactor-kotlin-extensions / reactor.kotlin.test / kotlin.Function0

Extensions for kotlin.Function0

testUsingVirtualTime

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

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