Как присоединиться к двум потокам событий в общем свойстве события?

Question

Рассмотрим следующие два потока событий. Каждое событие имеет свойство timestamp/ts и value.

Я хочу объединить эти два потока, где события имеют одинаковые метки времени, в результате поток с нанесенным преобразованием величины. Если в одном потоке отсутствует одна временная метка (например, желтый ts=3 в примере ниже), эту метку времени следует игнорировать.

Хотелось бы, чтобы решить эту проблему, используя реактивную библиотеки программирования, таких как xstream или rxjs. Я совершенно новичок в концепциях реактивного программирования, но если у кого-то есть другое предложение, я все уши. Благодаря!

Answer 1

Просто используйте combLatest и передайте только те комбинации, которые имеют соответствующую метку времени. Другие комбинации отображаются на 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.