资源订阅者的添加方法的用例是什么?



我无法找出resourcessubscriber的add(Disposable)方法的用例。

我认为add(Disposable)方法可以用于处理多个一次性物品。

但是,如果我想把一些订阅放在一起,我将使用compositessubscribe并从subscribeWith方法的返回值添加Disposables。而且,我想这种方式更容易阅读。

此外,我认为,当主要的可流动完成时,额外的可流动可能会被自动处置,因为已完成的可流动可能被认为是已处置的可流动。所以,我试着咆哮。

Flowable<Long> f1 = Flowable.interval(100L, TimeUnit.MILLISECONDS).take(3);
Flowable<Long> f2 = Flowable.interval(200L, TimeUnit.MILLISECONDS);
ResourceSubscriber<Long> s = new ResourceSubscriber<Long>() {
  ...
};
s.add(f2.subscribeWith(new DisposableSubscriber<Long>() {
  ...
}));
f1.subscribe(s);

f1完成后,f2继续工作。f2未处理。

现在,我想知道resourcessubscriber的add(Disposable)方法的好用例是什么。

ResourceSubscriber允许您注册Disposable资源。x Subscriber允许它,并且可以缓解从1的过渡。X到2。但是,它只跟踪资源,您必须在onErroronComplete实现中手动调用dispose来处置这些资源。

相关内容

  • 没有找到相关文章

最新更新