Rxjava booleanSupplier 预期

Question

您好，我正在尝试使用 rxjava repeatUntil 轮询请求，但出现了一些错误

下面是我的代码

accountDelegator.signUpReady(signUpRequest)
                .observeOn(Schedulers.io())
                .subscribeOn(AndroidSchedulers.mainThread())
                .repeatUntil { response -> 
                    if (response.isSuccesfull){
                        return onComplete()
                    }
            }

它说它需要一个 booleanSupplier 而不是一个单位？

我只是想重复上面的请求，直到我得到一个 response.isSuccessful 然后返回 onComplete() 就像在 rxjava 文档中它指出要退出 repeatUntil 观察者，你必须调用 onComplete

Answer 1

repeatUntil 不向其BooleanSupplier 函数提供任何项目，该函数应指示是否重复上游。要“退出”它，你必须从函数中返回 true，因为你不能在那里调用 onComplete（这也没有意义，你可能误解了文档）。

您可以改用 filter 和 take 来停止重复序列：

accountDelegator.signUpReady(signUpRequest)
            .subscribeOn(Schedulers.io())
            .repeat(/* 100 */)
            .filter { response -> response.isSuccessful }
            .take(1)
            .observeOn(AndroidSchedulers.mainThread());

您还希望通过repeatWhen 限制重试次数和/或将重复延迟一段时间（这样您的代码就不会因为不成功而向服务器发送垃圾邮件）。

编辑

要详细说明关于延迟重试的最后一句话，这里有一种方法：

.repeatWhen { completion -> completion.delay(1, TimeUnit.SECONDS) }

而不是repeat(100)。当上游完成时，通过completion 向对象发出信号，然后延迟 1 秒。之后，repeatWhen 中的另一端接收到触发重新订阅上游的对象。