(Essence) 05/08/2020 Việc sử dụng luồng dữ liệu không đồng bộ Angular RxJS

In lại Tác giả: Người biết Thời gian cập nhật: 2024-03-13 05:33:21 31 4

nhập { Thành phần, OnInit } từ '@angular/core'; nhập { CommonService } từ '../../services/common.service'; nhập { Có thể quan sát } từ 'rxjs'; rxjs/operators'; @Component({ selector: 'app-home', templateUrl: './home.comComponent.html', styleUrls: ['./home.comComponent.less'] }) lớp xuất HomeComponent triển khai OnInit { constructor(public common: CommonService) { } //Đăng ký dịch vụ ngOnInit(): void { //1. Gọi lại không đồng bộ this.common.getDatacb( (res) => { console.log(res) }); //2. Promise nhận được this.common.getPromise().then((res) => { console.log(res); }) //3. rxjs lấy dữ liệu không đồng bộ var rxData = this.common.geRxjstData(); var p1 = rxData.subscribe(res => { console.log(res); }) // 4. rxjs lấy dữ liệu không đồng bộ và thực thi this.common.getRxIntervalData().subscribe(res => { console.log(res); }) // 5. Hoàn tác hành động sau một giây setTimeout(() => { p1.unsubscribe(); }, 1000) //6. pipe var stream = this.common.streamFun(); val % 2 == 0), //Filter map(value => { return value * value; // Xử lý dữ liệu}) ) .subscribe(res => { console.log(res); }) } }

nhập { Tiêm } từ '@angular/core'; nhập { Có thể quan sát } từ "rxjs";//js thư viện @Injectable({ProvideIn: 'root' }) xuất lớp CommonService { constructor() { } ///Hàm gọi lại getDatacb(cb) { setTimeout(() => { cb('getCBdata') }, 1000) } //promise gets getPromise() { return new Promise((resolve, từ chối) => { setTimeout(() => { Resolve('Zhang San----promise'); // giải quyết('Zhang San----promise1'); // Resolve('Zhang San----promise2'); }, 1000) }) } //3. rxjs lấy dữ liệu không đồng bộ geRxjstData() { return new Observable(observer => { setTimeout(()) => { var username = 'Xiao Ming-- rxjs' Observer.next(username); }, 3000) }) } //4. rxjs thực thi getRxIntervalData() nhiều lần { return new Observable(observer => { var count = 0 ; setInterval(() => { count++; var username = 'Xiao Ming--rxjs-Interval' Observer.next(username + count); }, 1000) }) } // hứa: không có lệnh thu hồi và thực thi nhiều lần, nhưng Rxjs có streamFun() { return new Observable(observer => { let count = 0; setInterval(()) => { người quan sát.next(đếm++ }, 1000);

31 4 0

• rxjs - Toán tử xếp hàng cho RxJS

  Có toán tử nào trong RxJS cho phép tôi đệm các mục và loại bỏ từng mục một khi tín hiệu có thể quan sát được kích hoạt không? Giống như bộ đệmKhi, nhưng thay vì đổ toàn bộ bộ đệm vào mỗi tín hiệu, nó sẽ bỏ một lượng nhất định cho mỗi tín hiệu. Nó thậm chí có thể đổ tín hiệu o

• rxjs - shareReplayLatestwhileKết nối với RxJS

  Tôi đang tạo nguồn có thể quan sát của mình như thế này (gọi api cứ sau 5 giây): const obs$ = Observable.interval(5000).switchMap(() => makeApiCall())

• RxJS: Có điều gì cần quan sát không?

  Tôi có một Hành động sau đó sẽ kích hoạt yêu cầu ajax. Nếu hoạt động thất bại vì lý do nào đó, tôi không muốn làm gì cả. Thay vì tạo một hành động trống chỉ trả về trạng thái trước đó, tôi không có chức năng không làm gì mà tôi có thể làm? xuất mặc định f

• rxjs - Trước tiên, bạn cần hủy đăng ký RxJS()

  Trong đoạn mã sau: - RxJS.Observable.of(1,2).first().subscribe((x) => console.log(x););

• RXJS: Thời gian điều tiết cộng với giá trị cuối cùng

  Tôi gặp tình huống gửi nhiều sự kiện tới một luồng trong một khoảng thời gian ngắn. Tôi muốn một toán tử kết hợp giữa ojit_code và debounceTime. Bản demo sau có thể được sử dụng để minh họa những gì tôi muốn có https://stackblitz

• rxjs - RXJS: tổng số lần gỡ lỗi

  Trường hợp sử dụng của tôi như sau: Tôi nhận được các sự kiện, đôi khi đột ngột. Nếu xảy ra bùng phát, tôi chỉ phải giải quyết một lần. Debounce thực hiện điều này. Tuy nhiên, việc gỡ lỗi chỉ cung cấp cho tôi phần tử cuối cùng của cụm, nhưng tôi cần biết tất cả các phần tử trong cụm để tóm tắt (sử dụng chế độ xem kế hoạch). Điều này có thể

• Đăng ký lồng nhau của RxJs có thể quan sát?

  Cách để đơn giản hóa ví dụ mã sau đây là gì? Tôi không thể tìm thấy toán tử phù hợp.. Ai đó có thể đưa ra một ví dụ ngắn gọn không? this.returnsObservable1(...) .subscribe( thành công =>

• Sự hợp nhất tĩnh trong RxJS 6 ở đâu?

  Trong RxJS 6, làm cách nào để nhập hàm hợp nhất tĩnh để hợp nhất danh sách có thể quan sát? Tôi muốn có thể làm được: const merge$ = merge( obs1$, obs2$, obs3$

• rxjs - Sự khác biệt giữa kiểm tra và gỡ lỗi trong RxJS?

  Tôi đang đọc tài liệu chính thức của RxJS và sau đó tôi nhận ra rằng tất cả chúng đều làm điều tương tự. Đối với tôi chúng trông giống hệt nhau. Xin vui lòng chỉ ra nếu có bất kỳ sự khác biệt. Câu trả lời hay nhất Tôi sẽ mô tả sự khác biệt giữa chúng về phiên bản Thời gian, vì đó là điều tôi quen thuộc nhất

• rxjs - Các trường hợp sử dụng thông báo trong RxJS là gì?

  Tôi phần nào quen thuộc với các khái niệm RxJS cơ bản như Vật quan sát, Người quan sát và Chủ đề, nhưng khái niệm Thông báo RxJS hoàn toàn mới đối với tôi. Nó được sử dụng để làm gì? khi nào tôi nên

• rxjs - Không tìm thấy mô-đun 'rxjs' hoặc khai báo kiểu tương ứng của nó sau khi chuyển sang rxjs 7

  Sau khi chuyển từ rxjs 6.5 sang rxjs 7, tôi gặp phải lỗi lạ này. Tôi không chắc đây là sự cố loại với rxjs 7 hay với stackblitz (https://stackblitz.com/edit/r

• Làm cách nào để chỉ nhập các toán tử được sử dụng trong RxJS 6 như RxJS cũ mà không cần rxjs-compat?

  Trước đây tôi chỉ có thể nhập các toán tử đã sử dụng bằng mã này: import 'rxjs/Observable'; import 'rxjs/add/operator/map';

• typescript - Hàm RxJS CombineLatest có thể được nhập từ rxjs và rxjs/toán tử, sự khác biệt giữa hai hàm này là gì?

  Hàm CombineLatest có thể được nhập từ rxjs và rxjs/operators. Khi tôi nhập nó từ rxjs/toán tử (như tôi nhập tổ hợpTất cả, tôi gặp lỗi sau: TS23

• Làm cách nào để tạm dừng bộ đệm từ một nguồn trong RXJS?

  Tôi có một loạt sự kiện đang diễn ra fromEventPattern như thế này: fromEventPattern(addEventHandler).subscribe(ps$); Do những vấn đề kinh doanh, tôi cho rằng đôi khi một ngoại lệ sẽ được đưa ra

• rxjs - Thao tác một luồng các mục bằng RxJS để có được một chuỗi các mục

  Tôi mới sử dụng rxjs và không thể giải quyết vấn đề này: Tôi có hai luồng: một luồng có các đối tượng đến ---a----b----c----d----> một luồng có Đối tượng được chọn từ danh sách----c---->

• rxjs - Tôi có phải hủy đăng ký khỏi một sản phẩm có thể quan sát được trong rxjs không?

  Nếu một thành phần có thể quan sát hoàn tất, tôi vẫn cần hủy đăng ký/loại bỏ (trong RxJS) của thành phần có thể quan sát được để xóa Observer (để tránh rò rỉ bộ nhớ) hoặc một lần onComplete hoặc onErr

• Làm cách nào để đặt ngữ cảnh cho chức năng gọi lại đăng ký rxjs?

  Tôi có một đăng ký như thế này: this.test.subscribe(params => { ...some code }); Nếu tôi chuyển một hàm gọi lại thay vì một hàm mũi tên thì ngữ cảnh sẽ bị thiếu. Tôi muốn liên kết bối cảnh với

• rxjs - Cách trì hoãn phát chuỗi trong Rxjs

  Tôi có một thông tin có thể quan sát được: messages: string[] = ['a', 'b', 'c']; const source = from(messages) Làm thế nào để bạn trì hoãn nó, để khi ai đó đăng ký nó, nó sẽ

• rxjs - Cách phát ra các thay đổi dựa trên giá trị trong rxjs

  Tôi có thể tạo ra ngọn lửa có thể quan sát được một lần trên giá trị. Nhưng tôi muốn nó xảy ra khi giá trị của biến thay đổi. Thực ra tôi cần một người quan sát. Đây là những gì tôi nghĩ có thể quan sát được. Quan sát giá trị hoặc trạng thái của một vật và cập nhật đăng ký cho nó

• Làm cách nào để ngăn nhiều cuộc gọi tìm nạp trong RxJS?

  Tôi có đoạn mã sau: const getBook = (bookId: number) => { const title = 'Book' + bookId('