Комбинируйте внутренние конкатентные наблюдения

Question

Я новичок в RxJS и имеет ментальный блок. Мое решение работает, но я знаю, что это взломать. Каков правильный способ сделать следующее?

// Desired Console Log: {x: 'abcd', y: 'efgh'} 

const x = Rx.Observable.of('abcd').delay(1000); 
const y = Rx.Observable.of('efgh').delay(1000); 

Rx.Observable.concat(x,y) 
.scan((acc, cur) => { 
    if (cur.includes('a')) { 
    acc.x = cur; 
    } 
    if (cur.includes('e')) { 
    acc.y = cur; 
    } 
    return acc 
}, {x: false, y: false}) 
.filter(x => x.y === 'efgh') 
.subscribe(x => console.log(x)) 

// {x: 'abcd', y:'efgh'} 

Answer 1

Rx.Observable.concat(x,y) 
    .zipIterable(['x','y'], (v1, v2) => { 
    let result = {}; 
    result[v2] = v1; 
    return result; 
    }) 
    .toArray() 
    .map(objects => Object.assign({}, ...objects)) 
    .subscribe(console.log.bind(console, '>> ')); 

При условии, что порядок сохраняется, то есть первый элемент х, а второй у