RxAndroid :如何每分钟发出压缩可观察的?

Question

Observable<List<Stop>> zippedObservable = Observable.zip(observableList, objects -> {
List<Stop> stopList = Collections.emptyList();
for (Object obj : objects) {
stopList.add((Stop) obj);
}
return stopList;
});

我有一个 zippedObservable 变量，它被多个可观察量压缩。

disposable.add(zippedObservable.observeOn(AndroidSchedulers.mainThread())
.subscribeWith(new DisposableObserver<List<Stop>>() {
// onNext, onComplete, onError omitted
}));

此函数成功发出项目(压缩的停止列表)，但我想每分钟发出这些项目。我认为interval运算符非常适合这种情况，但我不知道如何混合zip和interval功能。

这就是我尝试过的

zippedObservale.interval() // cannot call interval operator here.
Observable.zip(...).interval() // cannot call interval operator here too.

我正在寻找某人来解释如何混合这两个运算符，以便我可以每分钟发出项目。谢谢。

Answer 1

interval

是一种静态方法，用于创建一个在给定周期或间隔发出Long的Observable<Long>。

要实现您所描述的内容，您需要使用一个这样的Observable来调整压缩Observable：

Observable<List<Stop>> zipped = ...;
Observable<Long> interval = Observable.interval(...);
Observable<List<Stop>> everyMinute = zipped.sample(interval);

在这种情况下，它每分钟最多只会发出一个zipped的结果，而不考虑zipped发出的任何其他结果。我不确定这就是你想要的。

如果只想一遍又一遍地重新发出相同的值，则可能需要在两者之间添加一个repeat()。