/* Using a disposable */

var source = Rx.Observable.create(observer => {

    observer.onNext(42);

    observer.onCompleted();

​

    // Note that this is optional, you do not have to return this if you require no cleanup

    return Rx.Disposable.create(() => console.log('disposed'));

});

​

var subscription = source.subscribe(

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

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

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

​

// => onNext: 42

// => onCompleted