我正在进行异步调用,在1分钟内每隔10秒钟大约会进行6次调用,但问题是我想在特定的条件
上应用延迟
Observable
.just(listOfSomethings_Locally)
.take(1, TimeUnit.MINUTES)
.serialize()
.delaySubscription( // this is confusing part
() ->
Observable.just(listOfItems_Network).take(10,TimeUnit.SECONDS)
)
我想做的是延迟网络调用10秒钟,除了第一次外,然后在10秒后取消网络调用,这样我应该在1分钟内得到6个精确的调用。
编辑:
由于场景不清晰,重新定义场景:
我有一个大型的本地驱动程序列表,我想每隔10秒向它们发送请求,并侦听另一个订阅者以检查是否在10秒内取消了驱动程序。这个过程将持续约1分钟,如果一个驱动程序被取消,我应该立即向下一个驱动程序发送请求。
目前为止编写的代码:
Observable.from(driversGot)
.take(1,TimeUnit.MINUTES)
.serialize()
.map(this::requestRydeObservable) // requesting for single driver from driversGot (it's a network call)
.flatMap(dif ->
Observable.amb(
kh.getFCM().driverCanceledRyde(), // listen for if driver cancel request returns integer
kh.getFCM().userRydeAccepted()) // listen for driver accept returns RydeAccepted object
.map(o -> {
if (o instanceof Integer) {
return new RydeAccepted();
} else if (o instanceof RydeAccepted) {
return (RydeAccepted) o;
}
return null;
}).delaySubscription(10,TimeUnit.SECONDS)
)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(fua -> {
if (fua == null) {
UiHelpers.showToast(context, "Invalid Firebase response");
} else if (!fua.getStatus()) { // ryde is canceled because object is empty
UiHelpers.showToast(context, "User canceled ryde");
} else { // ryde is accepted
UiHelpers.showToast(context, "User accepted ryde");
}
}, t -> {
t.printStackTrace();
UiHelpers.showToast(context,"Error sending driver requests");
}, UiHelpers::stopLoading);