Performing The Stream Equivalent Of Promise.all() Using RxJS