rxjs，subscription.unsubscribe 是不是一个函数？

Question

我不知道为什么subscription.unsubscribe 不是函数。

我想不通。

const Rx = require("rx");

const observable = Rx.Observable.create(function(observer) {
  observer.next(1);
  observer.next(2);
  const intervalId = setInterval(() => {
    observer.next('nmb');
  }, 1000);

  return function unsubscribe() {
    clearInterval(intervalId);
  }
});

const subscription = observable.subscribe(x => console.log(x));

setTimeout(() => {
  subscription.unsubscribe();
}, 5000);

Answer 1

针对 rxjs 5 api 编写代码但引用 rxjs 4 时遇到此问题。