RxJava - объединяет последовательность запросов в цикле

Question

Допустим, у меня есть 3 сервера (с одинаковым API):

| S1 | S2 | S3 |

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

Что мне нужно, это (в последовательности):

1. S1-postSomething(100) , S2-postSomething(100) , S3-postSomething(100)
2. Sleep
3. делать простые расчеты
4. S1-postSomething(90) , S2-postSomething(90) , S3-postSomething(90)
5. Sleep
6. сделать простой расчет из домена
7. S1-postSomething(80) , S2-postSomething(80) , S3-postSomething(80)
8. Sleep
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) {
    res = Observable.concat(
            res,
            service.postSomething([...], val),
            Observable.timer(5, TimeUnit.SECONDS)
    );
    val -= 10;
}
res.subscribe(); //completion handler will be invoked when done