//return basic observableconstsample= val =>Rx.Observable.of(val).delay(5000);/* convert each to promise and use Promise.all to wait for all to resolve*/constexample= () => {returnPromise.all([sample('Promise 1').toPromise(),sample('Promise 2').toPromise() ]);};//output: ["Promise 1", "Promise 2"]example().then(val => {console.log('Promise.all Result:', val);});