Observable Map

by Suman Kumar

HTML

<script src="https://cdnjs.cloudflare.com/ajax/libs/jquery/3.2.1/jquery.min.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.4.2/Rx.min.js"></script>

JavaScript

/**
Rx.Observable.range(0, 5).map(v => 'S1: '+v)
	.subscribe(v => console.log("Val : "+v));

Rx.Observable.range(6, 5).map(v => 'S2: '+v)
	.subscribe(v => console.log("Val : "+v));
  

Rx.Observable.of("Hello").subscribe(v => console.log('OBS ONE', v));
Rx.Observable.of(123).subscribe(v => console.log('OBS TWO', v));

var outer = Rx.Observable.interval(1000).take(5);

var source = outer.switchMap(function (x) {
  return Rx.Observable.interval(500).take(3).map(y => `${x}:${y}`)
});

source.subscribe(d => console.log(d));*/

['a','b','c']
	.flatMap(e => {
    return [e, e+ 'x', e+ 'y',  e+ 'z'  ];
	})
  .subscribe(v => console.log(v));