Rxjs 4使用console.log进行简单调试

问题描述：

我在rxjs的东西里很新，所以请耐心等待:)。Rxjs 4使用console.log进行简单调试

var source = Rx.Observable.fromEvent(document, 'keyup'); 
    source.filter(function(x){ 
     console.log('filter with', x); 
     return true; 
    }); 
    var subscription = source.subscribe(
     function (x) { 
     console.log('Next: keyup!',x.keyCode); 
     }, 
     function (err) { 
     console.log('Error: %s', err); 
     }, 
     function() { 
     console.log('Completed'); 
    });

什么正确的方式过滤器内调试我没有看到任何滤波器 控制台

我也试图与

var source = Rx.Observable.fromEvent(document, 'keyup'); 
    source.filter(function(x){ 
     console.log('filter with', x); 
     return true; 
    }); 
    source.do(x => console.log('do with',x)); 
    var subscription = source.subscribe(
     function (x) { 
     console.log('Next: keyup!',x.keyCode); 
     }, 
     function (err) { 
     console.log('Error: %s', err); 
     }, 
     function() { 
     console.log('Completed'); 
    });

没有幸运

你能给我一个提示吗？

答

source.filter（）正在创建一个新的Observable，但您只订阅了原始的Observable，source。未订阅不进行

观测你必须做这样的事情：

source.filter() 
     .do() 
     .subscribe()

Rxjs 4使用console.log进行简单调试

相关推荐