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

コードは問題ありません。私はあなたの正確なコードを取って単純に削除しました const Rx = require("rx") それは正常に動作します。 https://jsbin.com/newopavutu/edit?html,js,console,outputをチェックしてください。これがうまくいかない場合は、あなたの環境に何か間違っているはずです。