RxJava with RxAndroid example

gistfile1.txt

 @Before
    public void setUp() throws Exception {
        setupRxSchedulers();
    }

    private void setupRxSchedulers() {
        RxJavaHooks.setOnIOScheduler(current -> Schedulers.immediate());
        RxAndroidPlugins.getInstance().registerSchedulersHook(new RxAndroidSchedulersHook() {
            @Override
            public Scheduler getMainThreadScheduler() {
                return Schedulers.immediate(); // witchout this you would have to use wait in tests
            }
        });
    }


@Test
public void testMethod(){
        Observable<ArrayList<Object>> placesForLocation = fechObservable();
        TestSubscriber<ArrayList<Object>> testSubscriber = new TestSubscriber<>();
        placesForLocation.subscribe(testSubscriber);
}

@After
public void tearDown() {
   RxAndroidPlugins.getInstance().reset();
}