javascript - Get values from an array of promises - Stack Overflow

admin管理员组

文章数量:1344926

I've just started learning this amazing stuff. I can't figure out how to get values from an array of promises. Here's where am at:

const one = new Promise(resolve => {
  setTimeout(() => {
    resolve(1);
  }, 1000);
})
const two = new Promise(resolve => {
  setTimeout(() => {
    resolve(2);
  }, 2000);
})
const observable = Rx.Observable.from([one, two]);
observable.subscribe(v => console.log(v));

I get in console:

Promise { <pending> }
Promise { <pending> }

I'd like to get:

1. Result as an array of values [1,2]
2. Result as individual values in order of promise resolution 1,2

So, basically I want to emulate:

1. Promise.all([one, two])
2. Promise.resolve(1), Promise.resolve(2)

I've just started learning this amazing stuff. I can't figure out how to get values from an array of promises. Here's where am at:

const one = new Promise(resolve => {
  setTimeout(() => {
    resolve(1);
  }, 1000);
})
const two = new Promise(resolve => {
  setTimeout(() => {
    resolve(2);
  }, 2000);
})
const observable = Rx.Observable.from([one, two]);
observable.subscribe(v => console.log(v));

I get in console:

Promise { <pending> }
Promise { <pending> }

I'd like to get:

1. Result as an array of values [1,2]
2. Result as individual values in order of promise resolution 1,2

So, basically I want to emulate:

1. Promise.all([one, two])
2. Promise.resolve(1), Promise.resolve(2)

• javascript
• rxjs
• rxjs5

Share Improve this question Follow edited Jan 13, 2017 at 17:33 martin 97k2626 gold badges203203 silver badges235235 bronze badges asked Jan 13, 2017 at 16:04 manidosmanidos 3,46477 gold badges3939 silver badges7575 bronze badges 1

• This Post will answer your question stackoverflow./questions/30519645/… – aliegm Commented Jan 13, 2017 at 16:15

Add a ment  | 

1 Answer 1

Sorted by: Reset to default 12

Static method Observable.from() emits each item in the array so what you have right now will just emit two Promise objects:

You're dealing with so called Higher-order Observables (aka Observables emitting Observables). This is in RxJS 5 easily solvable with concatAll or mergeAll depending on whether you care about the order they are specified or they can be collected as the resolve.

RxJS 5 treats Observables, Promises, iterators, array (and array like objects) the same way. This means we use your Promises just like they were Observables.

I'm using mergeAll here to show that the second Promise finished first even though they're defined in the opposite order [one, two].

const one = new Promise(resolve => {
  setTimeout(() => {
    resolve(1);
  }, 1000);
})
const two = new Promise(resolve => {
  setTimeout(() => {
    resolve(2);
  }, 500);
})

// Result as individual values in order of promise resolution 2,1
Rx.Observable.from([one, two])
  .mergeAll()
  .subscribe(v => console.log('mergeAll: ' + v));

// Result as an array of values [2,1]
Rx.Observable.from([one, two])
  .concatAll()
  .toArray()
  .subscribe(v => console.log(v));

See live demo: https://jsbin./tigidon/4/edit?js,console

This prints to console:

mergeAll: 2
mergeAll: 1
[2, 1]

本文标签： javascriptGet values from an array of promisesStack Overflow