rxjs：</p> <pre><code>const programState$ = Rx.Observable.combineLatest( high$, low$, (high, low) => { return program(high, low); }); </code></pre> <p>これは結構な動作しますが、私もできるようにしたい：ストリームにリセットされ、唯一のアウトを取得するには、私は、次のようなものでcombineLatestに一緒に来る二つの別々のストリームを持つ

Question

を置きます高い$と低い$の両方を初期状態にリセットし、プログラムを1回だけ起動します。

const high$ = initialDataBranchOne$.merge(interactiveHigh$); 
const low$ = initialDataBranchTwo$.merge(interactiveLow$); 

これらの両方は、Eventから発せられたinitialDataストリームから来ています。プログラムが正常に実行されている間、combineLatestはうまく動作します。 initialData fromEventが発生したときに、同じ結果を得るにはどうすればよいですか？今すぐプログラムは2回実行されます。

Answer 1

同じオブジェクトにhighとlowのプロパティを格納できます。

// Define your default high/low values 
const defaultHighLow = /** **/; 

// Different types of updates/actions 
const highUpdate$ = high$.map(high => ({ high, type: 'UPDATE HIGH' })); 
const lowUpdate$ = low$.map(low => ({ low, type: 'UPDATE LOW' })); 
const resetUpdate$ = reset$.map(high => ({ type: 'RESET' })); 

// Merge all the different types of actions to single stream 
const update$ = Rx.Observable.merge(highUpdate$, lowUpdate$, resetUpdate$); 

// Scan over these updates to modify the high/low values 
const highLowState$ = update$.scan((state, update) => { 
    if (update.type === 'UPDATE HIGH') { 
    return { ...state, high: update.high }; 
    } 

    if (update.type === 'UPDATE LOW') { 
    return { ...state, low: update.low }; 
    } 

    // Return defaultHighLow if reset update is triggered 
    if (update.type === 'RESET') { 
    return defaultHighLow; 
    } 

    // Return state by default 
    return state; 
}, defaultHighLow).startWith(defaultHighLow); 

をそして最後に、我々は以前のように、プログラムの状態を導き出すことができます：様々なイベントがこの状態を更新するために来るよう私たちは、その後、scanを行うことができます

const programState$ = highLowState$.map(hl => program(hl.high, hl.low));