@Test
public void testObservableError() throws Exception {

    TestSubscriber<Object> subscriber = new TestSubscriber<>();
    Observable.error(new IOException())
            .compose(RxUtils.async())
            .compose(mLifecycleHandler.load(3))
            .subscribe(subscriber);
    subscriber.assertError(IOException.class);
}