/* Using Promises and Observable sequences */

var source1 = Rx.Observable.return(42);

var source2 = RSVP.Promise.resolve(56);

​

var source = Rx.Observable.concat(source1, source2);

​

var subscription = source.subscribe(

  x => console.log(`onNext: ${x}`),

  e => console.log(`onError: ${e}`),

  () => console.log('onCompleted'));

​

// => onNext: 42

// => onNext: 56

// => onCompleted