我希望将响应最大延迟500毫秒。 如果updateData花费了400毫秒,那么我希望延迟100毫秒。
以下代码总是延迟500毫秒。 目前,如果后端需要600毫秒,则总延迟为1100毫秒,但如果超过500毫秒,我不想延迟。
compositeDisposable.add(someRepo.updateData(dataRequest)
.observeOn(schedulerProvider.mainThread())
.delay(500, TimeUnit.MILLISECONDS)
.subscribeWith(dataUpdateObserver())