RxJS - Praca z subskrypcją

Kiedy to, co obserwowalne jest tworzone, aby wykonać obserwowalne, musimy je subskrybować.

operator count ()

Oto prosty przykład, jak zasubskrybować obserwowalny.

Przykład 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));

Wynik

The count is 6

Subskrypcja ma jedną metodę o nazwie unsubscribe (). Wywołanie metody unsubscribe () usunie wszystkie zasoby używane do tego obserwowalnego, tj. To, co obserwowalne, zostanie anulowane. Oto działający przykład użycia metody unsubscribe ().

Przykład 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();

Subskrypcja jest przechowywana w zmiennej test. Użyliśmy test.unsubscribe () the obserable.

Wynik

The count is 6