observable.js

var observableStream = Rx.Observable.create(function(observer) {
  observer.onNext(1);
});

var subscriber = observableStream.subscribe(function(data) {
  console.log('data', data);
  
  if (data) {
    subscriber.dispose();
  }
});