​

​

const one = new Promise(resolve => {

  setTimeout(() => {

    resolve(1);

  }, 1000);

})

const two = new Promise(resolve => {

  setTimeout(() => {

    resolve(2);

  }, 500);

})

​

// Rx.Observable.from([one, two])

//   .concatAll()

//   .subscribe(v => console.log('concatAll: ' + v));

​

// Rx.Observable.from([one, two])

//   .concatAll()

//   .toArray()

//   .subscribe(v => console.log(v));

​

Rx.Observable.from([one, two])

  .mergeAll()

  .subscribe(v => console.log('mergeAll: ' + v));

​

Rx.Observable.from([one, two])

  .mergeAll()

  .toArray()

  .subscribe(v => console.log(v));