दो आरएक्सजेएस धाराएं (सिंक्रनाइज़ पर आधारित) को मिलाएं

Question

मेरे पास दो आरएक्सजेएस विषय हैं, a और b कहें कि मुझे किसी भी तरह गठबंधन करने की आवश्यकता है।

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

मैं उन्हें इस तरह संयोजित करना चाहते हैं कि यदि a और b तुल्यकालिक अपडेट किया जाता है, मानों को एक साथ दिया जाता है:

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

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

हालांकि, अगर सिर्फ़ एक मान अद्यतन किया जाता है, एक अद्यतन अभी भी आगे बढ़ा दिया जाएगा साथ ही साथ दो नए मानों के साथ एक अद्यतन धक्का दिया जाएगा:

a.next(5) 

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

क्या यह संभव है? यदि ऐसा है, तो कैसे? यहां तक ​​कि यदि यह संभव है, तो क्या यह कुछ ऐसा है जो टालना चाहिए?

Answer 1

आप इच्छित व्यवहार को प्रभावित करने में सक्षम उपयोग एक Scheduler होना चाहिए:

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

ऊपर कोड उत्पादन निम्नलिखित होगा:

value: 3 4 

तो asapScheduler निर्दिष्ट नहीं है, उत्पादन होगा:

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

आरएक्सजेएस गिटहब रेपो में कुछ Scheduler documentation शामिल हैं।