ManagedScheduledFlowable implements Managed { public Flowable<Long> getFlowable() { return flowable; } ManagedScheduledFlowable(String name, Long interval, TimeUnit intervalUnit, Scheduler scheduler); @Override void start(); Flowable<Long> getFlowable(); @Override void stop();  }
@Test public void should_not_start_item_emission_when_not_started() throws Exception { List<Long> results = new ArrayList<>(); managedScheduledFlowable.getFlowable().subscribe(results::add); testScheduler.advanceTimeBy(2, TimeUnit.SECONDS); assertThat(results).isEmpty(); }