How to use 'Rx beobachtbar' in angular2

Question

let button = document.querySelector('.mbtn'); 
let lab = document.querySelector('.mlab'); 

let clickStream = Observable.fromEvent(button,'click'); 

let doubleClickStream = clickStream 
     .buffer(()=> clickStream.throttle(250)) 
     .map(arr => arr.length) 
     .filter(len => len === 2); 

doubleClickStream.subscribe(event =>{ 
     lab.textContent = 'double click'; 
}); 

    doubleClickStream.throttle(1000) 
     .subscribe(suggestion =>{ 
      lab.textContent = '-'; 
     }); 

Doppelklick zu lösen, aber das ist Fehler in meinem angular2 Projekt, die mich um es zu lösen helfen kann, dieser Fehler

↓ Log

ERROR in /Users/genilex3/Desktop/meager/angularRxjs/angularrxjs/src/app/app.component.ts (58,15): Argument des Typs '() => any' ist nicht dem Parameter vom Typ 'Observable zuweisbar ". Die Eigenschaft '_isScalar' fehlt im Typ '() => any'.

ERROR in /Users/genilex3/Desktop/meager/angularRxjs/angularrxjs/src/app/app.component.ts (58,41): Argument vom Typ 'Zahl' ist nicht zuordenbar Parameter Typ '(Wert: {}) => SubscribbleOrPromise'.

Answer 1

Sie sollten bufferTime für Ihren Stream verwenden.

let doubleClickStream = clickStream 
     .bufferTime(250) 
     .map(arr => arr.length) 
     .filter(len => len === 2); 

Hier können Sie mehr lesen: http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#instance-method-bufferTime

Wenn Sie Ihren Wert nach 1000 ms löschen, nachdem er eingestellt wurde, sollten Sie debounceTime Methode verwenden.

doubleClickStream.debounceTime(1000) 
    .subscribe(suggestion =>{ 
     lab.textContent = '-'; 
    }); 

Hier können Sie mehr über debounceTime lesen: http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#instance-method-debounceTime