내부 Concat Observables를 결합하십시오.

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

주문이 유지되도록 제공, 즉 첫 번째 요소는 X 및