@Test
public void testSecondSubscriptionDoesNotReceiveError() throws Exception {

    Observable<Object> resultObservable = Observable.concat(Observable.just(2, 3), Observable.error(new Exception()));
    TestSubscriber<Object> testSubscriber1 = new TestSubscriber<>();
    TestSubscriber<Object> testSubscriber2 = new TestSubscriber<>();
    resultObservable
            .compose(mLifecycleHandler.load(6))
            .subscribe(testSubscriber1);
    resultObservable
            .compose(mLifecycleHandler.load(6))
            .subscribe(testSubscriber2);
    testSubscriber1.assertValues(2, 3);
    testSubscriber1.assertError(Exception.class);
    testSubscriber2.assertValue(3);
    testSubscriber2.assertNotCompleted();
    testSubscriber2.assertNoErrors();
}