RxJS creating Observables in a loop

Question

I want to create Observables in a loop and wait for them all to be finished.

for (let slaveslot of this.fromBusDeletedSlaveslots) {
                    this.patchSlave({
                        Id: slaveslot.Id,
                        BusOrder: null,
                        BusId: null
                    });
                }

The patchSlave() Function returns a Observable.

patchSlave(slaveslot: any): Observable<any> {
    return this.httpClient.patch(environment.apiBaseUrl + `/odata/SlaveSlots(${slaveslot.Id})`, slaveslot);
}

I don't know the best way to solve this. I think I have to omit the loop a replace a with something from Rxjs?

Ankit Prajapati · Accepted Answer · 2020-04-17 05:56:24Z

2

Use here RxJS forkJoin operator.

You can pass array of observables, and it will give final value when all observables are completed.

let array = [];
for (let slaveslot of this.fromBusDeletedSlaveslots) {
               array.push ( this.patchSlave({
                        Id: slaveslot.Id,
                        BusOrder: null,
                        BusId: null
                    }));
                }

forkJoin(array).subscribe(results => {console.log(results)});

Refer here for more details : RxJS forkJoin

answered Apr 17, 2020 at 5:56

Ankit Prajapati

2,8303 gold badges14 silver badges23 bronze badges

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

2 Comments

Tim Sigl Over a year ago

Okay thank you very much!! Yeah I though of it. Is there a way without an array?

Sev Over a year ago

Consider using the merge? It's the next item in the provided link.

Collectives™ on Stack Overflow

RxJS creating Observables in a loop

1 Answer 1

2 Comments

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

2 Comments

Related