var requestStream, responseStream;

requestStream = Rx.Observable.from(['a','b','c','d','e']);

​

responseStream = requestStream.flatMap(

  sendRequest,

  (val, response)=>{ return {val, response}; }

);

​

responseStream.subscribe(

  item=>{

    console.log(item);

  },

  err => {

    console.log(err);

  },

  ()=>{

    console.log('Done');

  }

);

​

function sendRequest(val) {

  return new Promise((resolve,reject)=>{

    setTimeout(()=>{resolve('result for '+val);},1000);

  });

};