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

Question

假设我有 3 个服务器（具有相同的 API）：

|           S1            |           S2            |           S3            |

|   postSomething(data)   |   postSomething(data)   |   postSomething(data)   |

我需要的是这个（按顺序）：

1. S1-postSomething(100) , S2-postSomething(100) , S3-postSomething(100)

2. 睡觉

3. 做简单的计算

4. S1-postSomething(90) , S2-postSomething(90) , S3-postSomething(90)

5. 睡觉

6. 从域做简单的计算

7. S1-postSomething(80) , S2-postSomething(80) , S3-postSomething(80)

8. 睡觉

9. 做简单的计算

10. 完成所有 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) {&nbsp; &nbsp; res = Observable.concat(&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; res,&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; service.postSomething([...], val),&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Observable.timer(5, TimeUnit.SECONDS)&nbsp; &nbsp; );&nbsp; &nbsp; val -= 10;}res.subscribe(); //completion handler will be invoked when done