Rxjs und Winkel 2 und die Verwendung der "Take" -Operator

Question

Ich versuche, den "Take" -Operator in meinem Code (Lernen Rxjs) zu verwenden, aber es ist nicht die Top 5 wie ich will senden. Mein einfacher Code ist unten, jemand hat irgendeine Idee, wie man hilft?

Answer 1

Nach dem Lesen Ihres Kommentars, verstehe ich, dass Sie die ersten 5 Länder benötigen. Beachten Sie, dass Ihr Observable Arrays von Ländern und nicht von Ländern emittiert. Der Grund, warum Sie Observable.of anstelle von Observable.fr verwenden. So sollte die richtige Syntax sein:

this.countries = this.searchTerms.debounceTime(300).distinctUntilChanged().switchMap( 
     searchTerm => searchTerm ? this.countrySearchService.search(searchTerm) : observable.from<Country[]>([])) 
     .take(5); 

Wenn Sie eine Probe wollen, dass verschiedene Anwendungsfälle zeigen, haben einen Blick auf this jsbin.