Android中的RxJava：在没有生命周期时自动取消订阅

Question

我知道当您订阅可观察时，您会收到一个必须使用Android生命周期取消订阅的订阅。因此，对于片段或活动中的订阅，我使用onDestroy（）中的取消订阅。

但我的问题是，当我在没有任何生命周期的地方订阅时。例如，在SyncAdapter中。在这种情况下，我如何“自动取消订阅”以避免内存泄漏？在SyncAdapter中，有没有什么好的做法，比如说“永远不要在XXX位置订阅”，而我正在打破这种订阅？

我是这样想的：

compositeDisposable.add(
   Observable.just()...
   ...
   .doOnTerminate(compositeDisposable::dispose)
   .subscribe(...)
   );

Answer 1

您不仅可以“自动取消订阅”，还可以选择要取消订阅的线程。这是一个非常简单的例子

Observable<Object> source = Observable.using(
() -> {
    System.out.println("Subscribed on " + Thread.currentThread().getId());
    return Arrays.asList(1,2);
},
(ints) -> {
    System.out.println("Producing on " + Thread.currentThread().getId());
    return Observable.from(ints);
},
(ints) -> {
    System.out.println("Unubscribed on " + Thread.currentThread().getId());
}
);

source
.unsubscribeOn(Schedulers.newThread())
.subscribe(System.out::println);

输出应为

Subscribed on 1
Producing on 1
1
2
Unubscribed on 11

每个可组合的或一次性的或订阅都可以取消订阅。但请确保在流结束时执行此操作。注意线程问题。