RxJava - 在循环中组合请求序列

Question

假设我有 3 个服务器（具有相同的 API）：|           S1            |           S2            |           S3            ||   postSomething(data)   |   postSomething(data)   |   postSomething(data)   |我需要的是这个（按顺序）：S1-postSomething(100) , S2-postSomething(100) , S3-postSomething(100)睡觉做简单的计算S1-postSomething(90) , S2-postSomething(90) , S3-postSomething(90)睡觉从域做简单的计算S1-postSomething(80) , S2-postSomething(80) , S3-postSomething(80)睡觉做简单的计算完成所有 3 个计算后更新域几点注意事项：步骤 1、4、7 不必按顺序进行。但是必须在睡觉前完成所有 3 个请求（我在整个工作中使用了单线程线程池，因此 3 个帖子是按顺序进行的）。我不在乎postSomething(data)响应数据伪代码：int value = 100;List<Observable> tuning = new List()for (int tuningStep = 0; tuningStep < 10; tuningStep++) {    for (LampUnit lampUnit : lampUnits.getAllLampUnits()) {        // Don't care about response as long gettings success        Observable<Integer> post = service.postSomething(lampUnit.getId(), value);        result.add(post)    }    result.add(() -> {        Thread.sleep(5000L)        return 1;    });    result.add(() -> {        return doCalculations();    });    value -= 10;}result.subscribeOn(Schedulers.from(Executors.newFixedThreadPool(1))    .observeOn(Schedulers.from(this.executor))    .subscribe();

Answer 1

可能比你的更伪，但它可能暗示你想要的解决方案：

int val = 100;

Observable res = Observable.empty();

while(val >= 0) {

    res = Observable.concat(

            res,

            service.postSomething([...], val),

            Observable.timer(5, TimeUnit.SECONDS)

    );

    val -= 10;

}

res.subscribe(); //completion handler will be invoked when done