使用多个订阅服务器的RxJava2轮询

Question

>

糟糕的图案设计

仅在连接订阅服务器时才启动，如果没有可用的订阅服务器时停止

不成功共享数据，需要两个类（主题类和重复可观察类）

public class SingleTonClass { 
private PublishSubject<List<Data>> subject = PublishSubject.create();


public PublishSubject getSubject() {
    return this.subject;
}

public void setData(List<Data> data) { 
   subject.onNext(data);
}
}

我希望避免监听器/接口来共享周围的信息，让rxjava2来完成它的工作。

经过研究，我发现有refcount（）和share()，但我不确定这是否是解决这个问题的正确方法。在我的例子中，这是一个REST服务，它轮询服务器，如果至少有一个订阅服务器连接到其他地方，它应该如何停止轮询，因为在这种情况下获取数据是没有意义的。

我试图一次解决它，但它不起作用，除非：

使用RXJava2/rxandroid2和改型进行轮询

Answer 1

我会这样做：

Observable<Data> dataSource = Observable.interval(INTERVAL, TIME_UNIT)
    .observeOn(Schedulers.io()) // make REST requests on IO threads
    .map(n -> {
            return requestData();
        })
    .replay(1);

replay()运算符包括share()，后者又包括publish()和refcount()函数。这使得您可以观察到的热，即所有订阅者共享单一订阅。它自动向第一个订阅者订阅（启动新的interval序列），并在最后一个订阅者消失时取消订阅（停止interval)。

replay(1)还缓存上次发出的值，即新订阅服务器不必等待新数据到达。