एक सामान्य घटना संपत्ति पर दो ईवेंट स्ट्रीम में कैसे शामिल हों?

Question

निम्नलिखित दो ईवेंट स्ट्रीमों पर विचार करें। प्रत्येक कार्यक्रम में टाइमस्टैंप/टीएस और मूल्य संपत्ति होती है।

मैं मूल्य का एक आवेदन किया परिवर्तन के साथ एक है, जिसके परिणामस्वरूप धारा में, इन दो धाराओं जहां घटनाओं में एक ही टाइम स्टाम्प्स है संयोजित करना चाहते हैं। यदि एक स्ट्रीम में एक टाइमस्टैम्प गुम है (जैसे पीले ts=3 नीचे दिए गए उदाहरण में), तो उस टाइमस्टैम्प को अवहेलना किया जाना चाहिए।

जैसे xstream या rxjs एक प्रतिक्रियाशील प्रोग्रामिंग पुस्तकालय का उपयोग कर समस्या का समाधान करना चाहते हैं। मैं प्रतिक्रियाशील प्रोग्रामिंग की अवधारणाओं के लिए काफी नया हूं, लेकिन अगर किसी के पास कोई अन्य सुझाव है तो मैं सभी कान हूं। धन्यवाद!

Answer 1

बस गठबंधन का उपयोग करें और केवल उन संयोजनों को पास करें जिनमें मिलान करने वाला टाइमस्टैम्प है। अन्य संयोजनों को null पर मैप किया गया है, जिसे आप बाद में फ़िल्टर करते हैं।

यहाँ Xstream में समाधान है:

var streamOut = xs.combine(
    (a, b) => { 
    if (a.ts === b.ts) { 
     return {ts: a.ts, value: a.value + b.value}; 
    } else { 
     return null; 
    } 
    }, 
    streamA, streamB 
).filter(x => x !== null); 

JSBin में चल रहा यह जाँच करें: https://jsbin.com/saxawatuza/edit?js,console।