RxJS - Arbeiten mit Abonnement

Wenn das Observable erstellt wird, müssen wir es abonnieren, um das Observable auszuführen.

count () Operator

Hier ist ein einfaches Beispiel dafür, wie man ein Observable abonniert.

Beispiel 1

import { of } from 'rxjs';
import { count } from 'rxjs/operators';

let all_nums = of(1, 7, 5, 10, 10, 20);
let final_val = all_nums.pipe(count());
final_val.subscribe(x => console.log("The count is "+x));

Ausgabe

The count is 6

Das Abonnement verfügt über eine Methode namens unsubscribe (). Ein Aufruf der Methode unsubscribe () entfernt alle für dieses Observable verwendeten Ressourcen, dh das Observable wird abgebrochen. Hier ist ein funktionierendes Beispiel für die Verwendung der Methode unsubscribe ().

Beispiel 2

import { of } from 'rxjs';
import { count } from 'rxjs/operators';

let all_nums = of(1, 7, 5, 10, 10, 20);
let final_val = all_nums.pipe(count());
let test = final_val.subscribe(x => console.log("The count is "+x));
test.unsubscribe();

Das Abonnement wird im Variablentest gespeichert. Wir haben test.unsubscribe () the Observable verwendet.

Ausgabe

The count is 6