Rxjs 4 einfaches debug mit console.log

Question

Ich bin ziemlich neu bei rxjs Zeug also bitte Geduld :).

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'); 
    }); 

was ist der richtige Weg im Inneren Filter zu debuggen Ich sehe nicht, jede Filter mit in der Konsole

ich auch mit

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'); 
    }); 

ohne Glück

versucht haben

Können Sie mir bitte einen Hinweis geben?

Answer 1

source.filter() erstellt eine neue Observable, aber Sie abonnieren nur die ursprüngliche Observable, Quelle. Observablen, die nicht angemeldet sind, nicht durchgeführt werden

Sie haben so etwas zu tun:

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