testUsingVirtualTime |
Extension for testing a Publisher with StepVerifier API, using a VirtualTimeScheduler. fun <T> Publisher<T>.testUsingVirtualTime(vtsLookup: () -> VirtualTimeScheduler, n: Long): FirstStep<T> fun <T> Publisher<T>.testUsingVirtualTime(options: StepVerifierOptions): FirstStep<T> |