With 1.x this test pass:
@Test
public void subscriberShouldBeUnsubscribed() {
rx.observers.TestSubscriber subscriber = new rx.observers.TestSubscriber();
rx.Observable.just("").subscribe(subscriber);
subscriber.awaitTerminalEvent();
subscriber.assertNoErrors();
subscriber.assertCompleted();
subscriber.assertUnsubscribed();
}
But with 2.x this test does not pass:
@Test
public void observerShouldBeDisposed() {
TestObserver observer = new TestObserver();
Observable.just("").subscribe(observer);
observer.awaitTerminalEvent();
observer.assertNoErrors();
observer.assertComplete();
assertThat(observer.isDisposed(), is(true));
}
I think that dispose is similar to unsubscribe (but maybe I'm wrong). So I was wondering if this is the expected behaviour.
Thanks.