Kết hợp hai luồng RxJS (dựa trên đồng bộ)

Question

Tôi có hai đối tượng RxJS, giả sử a và b mà tôi cần kết hợp bằng cách nào đó.

someComboOfAandB.subscribe({aVal, bVal} => console.log("value:", aVal, bVal)); 

Tôi muốn kết hợp chúng như vậy mà nếu a và b được cập nhật đồng bộ, các giá trị được giao với nhau:

a.next(1); 
// some code 
b.next(2) 

// at end of synchronous code/frame: 
// value: 1 2 

Tuy nhiên, nếu chỉ là một giá trị được cập nhật, một bản cập nhật sẽ vẫn được đẩy đồng thời cập nhật với hai giá trị mới sẽ được đẩy:

a.next(5) 

// at end of synchronous code/frame: 
// value: 5 2 

Điều này có thể không? Nếu có, thì sao? Ngay cả khi nó có thể, nó là cái gì đó nên tránh?

Answer 1

Bạn sẽ có thể sử dụng một Scheduler để thực hiện hành vi mà bạn muốn:

import "rxjs/add/observable/combineLatest"; 
import "rxjs/add/operator/map"; 

import { BehaviorSubject } from "rxjs/BehaviorSubject"; 
import { Observable } from "rxjs/Observable"; 
import { asap } from "rxjs/scheduler/asap"; 

let a = new BehaviorSubject(1); 
let b = new BehaviorSubject(2); 
let combined = Observable 
    .combineLatest(a, b, asap) 
    .map((values) => ({ aVal: values[0], bVal: values[1] })); 

combined.subscribe(
    ({ aVal, bVal }) => { console.log("value:", aVal, bVal); } 
); 

a.next(3); 
b.next(4); 

Đoạn mã trên sẽ đưa ra như sau:

value: 3 4 

Nếu asapScheduler không được xác định, sản lượng sẽ là:

value: 1 2 
value: 3 2 
value: 3 4 

RxJS GitHub repo chứa một số Scheduler documentation.