RxJS - Abonelikle Çalışma

Gözlenebilir olan yaratıldığında, gözlemlenebilir olanı yürütmek için ona abone olmamız gerekir.

count () operatörü

Burada, gözlemlenebilir bir cihaza nasıl abone olunacağına dair basit bir örnek var.

örnek 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));

Çıktı

The count is 6

Aboneliğin unsubscribe () adlı bir yöntemi vardır. Unsubscribe () yöntemine yapılan bir çağrı, bu gözlemlenebilir için kullanılan tüm kaynakları kaldıracak, yani gözlemlenebilir olan iptal edilecektir. Unsubscribe () yöntemini kullanmanın çalışan bir örneğini burada bulabilirsiniz.

Örnek 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();

Abonelik, değişken testinde saklanır. Gözlemlenebilir olan test.unsubscribe () kullandık.

Çıktı

The count is 6