重用订户

Question

在RxJava中，我有一个订阅者对象，其中我订阅了可观察的。稍后（在调用on完整（）后的一段时间）我创建了一个新的可观察的并使用之前使用的相同订阅者实例进行订阅。但是，这似乎不起作用。订阅者不能重用吗？

示例：

class Loader extends Subscriber<T> {

   public void load(){
       Observable.just("Foo").subscribe(this);
   }

   public void onComplete(){
     // update UI
   }

}

在我的代码中，我想实例化Loader一次，并多次调用load（），例如在用户单击刷新按钮后...

Answer 1

使用Observable：：concat创建一个Observable，该Observable按顺序从多个Observable中发出项目。订阅。

Answer 2

您不能重用订阅服务器，因为它实现了订阅，其中有一个字段，一旦设置为true，就再也不会变为false，因此订阅不能重用。

另一方面，Observer不包含有关订阅状态的任何信息，因此您可以重用它。每次您将观察者订阅到可观察者时，RxJava实现都会为您将其打包到新的订阅者中。