JS Bin

/* Using Observables */

var array = [1, 2, 3];

​

var source = Rx.Observable.for(

    array,

    x => Rx.Observable.returnValue(x)

);

​

var subscription = source.subscribe(

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

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

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

​

// => onNext: 1

// => onNext: 2

// => onNext: 3

// => onCompleted