Scan-Operator mit asynchronem Code

Question

ich normalerweise wie dieser Abtastverwendungskanalliste:

Observable.interval(10).take(10).scan((acc, x) => acc.concat(x), []).subscribe...

nun im ersten Parameter der Scan anstelle einer synchronen Methode Ich mag eine Methode zu übergeben, die (acc bekommt, x) und returns Observable of new acc. (z. B. eine Methode, die in dB speichert und das gespeicherte Objekt mit Informationen zurückgibt, die von db kommen, wie Revisionsnummer, die dann im Akkumulator hinzugefügt wird).

Ich fand die mergeScan operator, die genau die Signatur zu haben scheint, die ich will, aber ich finde kein Beispiel und wenn ich es versuche, bekomme ich Property 'mergeScan' does not exist on type Observable<number>.

Was ich versuchte, ist dies:

Observable.interval(10).take(10) 
     .mergeScan((acc, x) => Observable.of(acc.concat(x)), []) 
     .subscribe(x => console.log(x)); 

I rxjs5 in Angular2

Answer 1

Ich verwende diesen Operator in der Version 5.0.0-beta.6 von Rxjs sehen kann.

Haben Sie versuchen, den Betreiber auf diese Weise zu importieren:

import 'rxjs/add/operator/mergeScan';