RxJS - Làm việc với Đăng ký

Khi cái có thể quan sát được tạo, để thực thi cái có thể quan sát được, chúng ta cần đăng ký nó.

toán tử count ()

Đây là một ví dụ đơn giản về cách đăng ký một chương trình có thể quan sát được.

ví dụ 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));

Đầu ra

The count is 6

Đăng ký có một phương thức được gọi là unsubscribe (). Một cuộc gọi đến phương thức unsubscribe () sẽ loại bỏ tất cả các tài nguyên được sử dụng cho có thể quan sát được, tức là có thể quan sát được sẽ bị hủy bỏ. Đây là một ví dụ hoạt động của việc sử dụng phương thức unsubscribe ().

Ví dụ 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();

Đăng ký được lưu trữ trong thử nghiệm biến. Chúng tôi đã sử dụng test.unsubscribe () có thể quan sát được.

Đầu ra

The count is 6