RxJs-MergeMap

mergeMap Operators

by manoj_antony32

HTML

<script src="https://unpkg.com/@reactivex/[email protected]/dist/global/Rx.js"></script>

<input type="text" id="input1" />
<input type="text" id="input2" />

Combined Value: <span></span>

JavaScript

var input1 = document.querySelector('#input1');
var input2 = document.querySelector('#input2');

var span = document.querySelector('span');

var obs1 = Rx.Observable.fromEvent(input1, 'input');
var obs2 = Rx.Observable.fromEvent(input2, 'input');

//Basic solution with outer and inner observable combined
/* obs1.subscribe(res1 => {
  obs2.subscribe(res2 => console.log(res1.target.value +' '+res2.target.value))
}
); */

obs1.mergeMap(event1 => {
 return obs2.map(event2 => event1.target.value+' '+event2.target.value)
}).subscribe(result => span.textContent = result)