RxJava - Combine sequence of requests in loop

Question

Lets say I have 3 servers (with same API):

| S1 | S2 | S3 |

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

What I need is this (in sequence):

S1-postSomething(100) , S2-postSomething(100) , S3-postSomething(100)
Sleep
do simple calculatios
S1-postSomething(90) , S2-postSomething(90) , S3-postSomething(90)
Sleep
do simple calculation from domain
S1-postSomething(80) , S2-postSomething(80) , S3-postSomething(80)
Sleep
do simple calculations
Update domain after done with all 3 calculations made

Few notes:

Steps 1,4,7 doesn't have to be in sequence. but has to finish all 3 requests before going to sleep (I used single thread thread pool for the whole job, so the 3 post is in sequence).
I don't care about postSomething(data) response data

pseudo code:

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();

Unqualified comment: I didn't grasp the full extent of your goal, but it sounds like the static methods Observable.zip, Observable.concat or Observable.merge might be helpful here. — Link64
– Link64, Commented Aug 29, 2018 at 10:15

Link64 · Accepted Answer · 2018-08-29 10:25:56Z

1

Probably more pseudo than yours, but it may hint at your desired solution:

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

answered Aug 29, 2018 at 10:25

Link64

7804 silver badges23 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

RxJava - Combine sequence of requests in loop

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related