RxJS - Lavorare con l'abbonamento

Quando l'osservabile viene creato, per eseguire l'osservabile dobbiamo sottoscriverlo.

operatore count ()

Ecco un semplice esempio di come iscriversi a un osservabile.

Esempio 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));

Produzione

The count is 6

L'abbonamento ha un metodo chiamato unsubscribe (). Una chiamata al metodo unsubscribe () rimuoverà tutte le risorse usate per quell'osservabile, cioè l'osservabile verrà cancellato. Ecco un esempio funzionante dell'utilizzo del metodo unsubscribe ().

Esempio 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();

L'abbonamento viene memorizzato nella variabile test. Abbiamo usato test.unsubscribe () l'osservabile.

Produzione

The count is 6