Cuando se crea el observable, para ejecutar el observable debemos suscribirnos a él.
operador count ()
A continuación, se muestra un ejemplo sencillo de cómo suscribirse a un observable.
Ejemplo 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));
Salida
The count is 6
La suscripción tiene un método llamado unsubscribe (). Una llamada al método unsubscribe () eliminará todos los recursos utilizados para ese observable, es decir, el observable se cancelará. Aquí hay un ejemplo práctico del uso del método unsubscribe ().
Ejemplo 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();
La suscripción se almacena en la variable test. Hemos utilizado test.unsubscribe () el observable.
Salida
The count is 6