null).expectNext("foo", "bar")
.expectComplete()
.toSubscriber();
flux.subscribe(s);
flux.subscribe(s);
<BUG>s.verify();
}</BUG>
@Test(timeout = 4000)
public void manuallyManagedVirtualTime() {
VirtualTimeScheduler vts = VirtualTimeScheduler.create();

null).expectNext("foo", "bar")
.expectComplete()
.toSubscriber();
flux.subscribe(s);
flux.subscribe(s);
assertThatExceptionOfType(AssertionError.class)
.isThrownBy(s::verify)
.withMessageStartingWith("expectation failed (an unexpected Subscription has been received");
}
@Test(timeout = 4000)
public void manuallyManagedVirtualTime() {
VirtualTimeScheduler vts = VirtualTimeScheduler.create();
