Ortak etkinlik özelliğinde iki olay akışına nasıl katılır?

Question

Aşağıdaki iki olay akışını göz önünde bulundurun. Her olayın bir zaman damgası/ts ve değer özelliği vardır.

ben değeri, uygulanan transformasyon ile elde edilen akımı içine, etkinlik, aynı zaman damgaları, bu iki akım birleştirmek istiyorum. Bir akışta bir zaman damgası eksikse (aşağıdaki örnekte sarı ts=3 gibi), bu zaman damgası göz ardı edilmelidir.

reaktif bir programlama kütüphanesi gibi xstream veya rxjs kullanarak sorunu çözmek ister misiniz. Reaktif programlama kavramlarına oldukça yeniyim, ama başka bir öneri varsa hepsi benim kulakım. Teşekkürler!

Answer 1

Sadece birleştiriciyi kullanın ve yalnızca eşleşen zaman damgası olan kombinasyonları iletin. Diğer kombinasyonlar daha sonra filtreleyebileceğiniz null ile eşlenir.

İşte xstream içinde çözüm:

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 içinde çalışmasını kontrol edin: https://jsbin.com/saxawatuza/edit?js,console.