using rx.js queries with promises

test-rx.js

    let value = 20;

    Rx.Observable.defer(() => {
      return Rx.Observable.fromPromise(Promise.try(() => {
        console.log('test/rx.js: 16');
        console.log(value);

        return value -= 1;
      }));
    })
    .repeat()
    .takeWhile(() => {
      return Promise.try(() => {
        console.log('test/rx.js: 22');
        console.log(value);

        return value > 10;
      });
    })
    .subscribe(
      (val) => {
        console.log('test/rx.js: 31');
        console.log(val);
      },
      (err) => {
        console.log(err.stack);
      });