java - RxJava2 在调用完成或错误时会自动处理可观察对象吗？

Question

我对 RxJava 上的处理有疑问。我在 Github 上的 RxSwift 文档中找到了下面这句话。

When a sequence sends the completed or error event all internal resources that compute sequence elements will be freed.

To cancel production of sequence elements and free resources immediately, call dispose on the returned subscription.

如果我理解正确，资源(可观察对象)将在调用 onCompleted 或 onError 后被释放。

那么问题来了，RxJava 是做和 RxSwift 一样的事情还是我需要自己调用 dispose？

Answer 1

是的，所有关联的资源都将自动处理。为了说明使用 RxJava 2 运行以下测试:

boolean isDisposed = false;

@Test 
public void testDisposed(){
    TestObserver<Integer> to = Observable.<Integer>create(subscriber -> {
        subscriber.setDisposable(new Disposable() {

            @Override
            public boolean isDisposed() {
                return isDisposed;
            }

            @Override
            public void dispose() {
                isDisposed = true;
            }
        });
        subscriber.onComplete();
    }).test();

    to.assertComplete();
    assertTrue(isDisposed);
}