How would I test a no events yet logic with from RxJava with Project Reactor Stepverifier?
How would I test a no events yet logic with from RxJava with Project Reactor Stepverifier? I'm currently trying to figure out, how to do a similar test in Project Reactor. Basically I want to ensure that before connect no events occur. @Test void connectable() { Observable<String> provider = Observable.just("Test1", "Test2"); ConnectableObservable<String> connectable = provider.publish(); TestObserver<String> testSubscriber = connectable.test(); testSubscriber.assertEmpty(); connectable.connect(); testSubscriber.assertResult("Test1", "Test2").assertComplete(); } This is my current attempt, but it is not correct, how would I get this to work? @Test void connectable() { Flux<String> provider = Flux.just("Test1", "Test2"); ConnectableFlux<String> connectable = provider.publish(); FirstStep<String> tester = StepVerifier.create(connectable).expectNoEvent(Du...