@Test public void testGetFluxWeedFlowable() { TestSubscriber<Object> testSubscriber = TestSubscriber.create(); magicalDataSource.getFluxWeedFlowable().subscribe(testSubscriber); testSubscriber.awaitTerminalEvent(); testSubscriber.assertNoErrors(); testSubscriber.assertComplete(); }
@Override public Flowable<FluxWeed> getFluxWeedFlowable() { return Flowable.just(new FluxWeed()) .delay(randomizer.randomInRange(2, 5), TimeUnit.SECONDS); }
MagicalRemoteDataSource implements MagicalDataSource { @Override public Flowable<FluxWeed> getFluxWeedFlowable() { return Flowable.just(new FluxWeed()) .delay(randomizer.randomInRange(2, 5), TimeUnit.SECONDS); } }
MagicalRemoteDataSource implements MagicalDataSource { @Override public Flowable<FluxWeed> getFluxWeedFlowable() { return Flowable.just(new FluxWeed()) .delay(randomizer.randomInRange(2, 5), TimeUnit.SECONDS); } @Inject  MagicalRemoteDataSource(Randomizer randomizer); }
MagicalRemoteDataSource implements MagicalDataSource { @Override public Flowable<FluxWeed> getFluxWeedFlowable() { return Flowable.just(new FluxWeed()) .delay(randomizer.randomInRange(2, 5), TimeUnit.SECONDS); } @Inject  MagicalRemoteDataSource(Randomizer randomizer); @Override Observable<FluxWeed> getFluxWeed(); @Override Flowable<FluxWeed> getFluxWeedFlowable(); }
MagicalRemoteDataSource implements MagicalDataSource { @Override public Flowable<FluxWeed> getFluxWeedFlowable() { return Flowable.just(new FluxWeed()) .delay(randomizer.randomInRange(2, 5), TimeUnit.SECONDS); } @Inject  MagicalRemoteDataSource(Randomizer randomizer); @Override Observable<FluxWeed> getFluxWeed(); @Override Flowable<FluxWeed> getFluxWeedFlowable();  }