d3trax
8/11/2016 - 6:33 PM

RxJS 5 Operators // source http://jsbin.com/gafede

RxJS 5 Operators

// source http://jsbin.com/gafede

jsbin.gafede.js
content_copyfile_download
"use strict";
var concurrent = 4;
var delay = 500;
var source = Rx.Observable.from(['1', '2', '3', '4', '5', '6', '7', '8', '9']);
var example = source.mergeMap(function (item) {
    return Rx.Observable.of(item).delay(1000);
}, function (v, v2) { return v2; }, concurrent);
var subscribe = example.subscribe(function (val) { return console.log(val); });
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoianNiaW4uanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyJqc2Jpbi50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsSUFBTSxVQUFVLEdBQUcsQ0FBQyxDQUFDO0FBQ3JCLElBQU0sS0FBSyxHQUFHLEdBQUcsQ0FBQztBQUVsQixJQUFNLE1BQU0sR0FBRyxFQUFFLENBQUMsVUFBVSxDQUFDLElBQUksQ0FBQyxDQUFDLEdBQUcsRUFBQyxHQUFHLEVBQUMsR0FBRyxFQUFDLEdBQUcsRUFBQyxHQUFHLEVBQUMsR0FBRyxFQUFDLEdBQUcsRUFBQyxHQUFHLEVBQUMsR0FBRyxDQUFDLENBQUMsQ0FBQztBQUV6RSxJQUFNLE9BQU8sR0FBRyxNQUFNLENBQUMsUUFBUSxDQUFDLFVBQVUsSUFBSTtJQUN6QyxNQUFNLENBQUMsRUFBRSxDQUFDLFVBQVUsQ0FBQyxFQUFFLENBQUMsSUFBSSxDQUFDLENBQUMsS0FBSyxDQUFDLElBQUksQ0FBQyxDQUFBO0FBQzVDLENBQUMsRUFDRCxVQUFDLENBQUMsRUFBRSxFQUFFLElBQUssT0FBQSxFQUFFLEVBQUYsQ0FBRSxFQUFFLFVBQVUsQ0FBQyxDQUFDO0FBRTdCLElBQU0sU0FBUyxHQUFHLE9BQU8sQ0FBQyxTQUFTLENBQUMsVUFBQSxHQUFHLElBQUksT0FBQSxPQUFPLENBQUMsR0FBRyxDQUFDLEdBQUcsQ0FBQyxFQUFoQixDQUFnQixDQUFDLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJjb25zdCBjb25jdXJyZW50ID0gNDtcbmNvbnN0IGRlbGF5ID0gNTAwO1xuXG5jb25zdCBzb3VyY2UgPSBSeC5PYnNlcnZhYmxlLmZyb20oWycxJywnMicsJzMnLCc0JywnNScsJzYnLCc3JywnOCcsJzknXSk7XG5cbmNvbnN0IGV4YW1wbGUgPSBzb3VyY2UubWVyZ2VNYXAoZnVuY3Rpb24gKGl0ZW0pIHtcbiAgICAgcmV0dXJuIFJ4Lk9ic2VydmFibGUub2YoaXRlbSkuZGVsYXkoMTAwMClcbiAgfSxcbiAgKHYsIHYyKSA9PiB2MiwgY29uY3VycmVudCk7XG5cbmNvbnN0IHN1YnNjcmliZSA9IGV4YW1wbGUuc3Vic2NyaWJlKHZhbCA9PiBjb25zb2xlLmxvZyh2YWwpKTsiXX0=
index.html
content_copyfile_download
<!DOCTYPE html>
<html>
<head>
  <meta charset="utf-8">
  <meta name="viewport" content="width=device-width">
  <title>RxJS 5 Operators</title>
  <script src="https://npmcdn.com/@reactivex/rxjs@5.0.0-beta.3/dist/global/Rx.umd.js"></script>
</head>
<body>

<script id="jsbin-javascript">
"use strict";
var concurrent = 4;
var delay = 500;
var source = Rx.Observable.from(['1', '2', '3', '4', '5', '6', '7', '8', '9']);
var example = source.mergeMap(function (item) {
    return Rx.Observable.of(item).delay(1000);
}, function (v, v2) { return v2; }, concurrent);
var subscribe = example.subscribe(function (val) { return console.log(val); });
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoianNiaW4uanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyJqc2Jpbi50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsSUFBTSxVQUFVLEdBQUcsQ0FBQyxDQUFDO0FBQ3JCLElBQU0sS0FBSyxHQUFHLEdBQUcsQ0FBQztBQUVsQixJQUFNLE1BQU0sR0FBRyxFQUFFLENBQUMsVUFBVSxDQUFDLElBQUksQ0FBQyxDQUFDLEdBQUcsRUFBQyxHQUFHLEVBQUMsR0FBRyxFQUFDLEdBQUcsRUFBQyxHQUFHLEVBQUMsR0FBRyxFQUFDLEdBQUcsRUFBQyxHQUFHLEVBQUMsR0FBRyxDQUFDLENBQUMsQ0FBQztBQUV6RSxJQUFNLE9BQU8sR0FBRyxNQUFNLENBQUMsUUFBUSxDQUFDLFVBQVUsSUFBSTtJQUN6QyxNQUFNLENBQUMsRUFBRSxDQUFDLFVBQVUsQ0FBQyxFQUFFLENBQUMsSUFBSSxDQUFDLENBQUMsS0FBSyxDQUFDLElBQUksQ0FBQyxDQUFBO0FBQzVDLENBQUMsRUFDRCxVQUFDLENBQUMsRUFBRSxFQUFFLElBQUssT0FBQSxFQUFFLEVBQUYsQ0FBRSxFQUFFLFVBQVUsQ0FBQyxDQUFDO0FBRTdCLElBQU0sU0FBUyxHQUFHLE9BQU8sQ0FBQyxTQUFTLENBQUMsVUFBQSxHQUFHLElBQUksT0FBQSxPQUFPLENBQUMsR0FBRyxDQUFDLEdBQUcsQ0FBQyxFQUFoQixDQUFnQixDQUFDLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJjb25zdCBjb25jdXJyZW50ID0gNDtcbmNvbnN0IGRlbGF5ID0gNTAwO1xuXG5jb25zdCBzb3VyY2UgPSBSeC5PYnNlcnZhYmxlLmZyb20oWycxJywnMicsJzMnLCc0JywnNScsJzYnLCc3JywnOCcsJzknXSk7XG5cbmNvbnN0IGV4YW1wbGUgPSBzb3VyY2UubWVyZ2VNYXAoZnVuY3Rpb24gKGl0ZW0pIHtcbiAgICAgcmV0dXJuIFJ4Lk9ic2VydmFibGUub2YoaXRlbSkuZGVsYXkoMTAwMClcbiAgfSxcbiAgKHYsIHYyKSA9PiB2MiwgY29uY3VycmVudCk7XG5cbmNvbnN0IHN1YnNjcmliZSA9IGV4YW1wbGUuc3Vic2NyaWJlKHZhbCA9PiBjb25zb2xlLmxvZyh2YWwpKTsiXX0=
</script>



<script id="jsbin-source-javascript" type="text/javascript">const concurrent = 4;
const delay = 500;

const source = Rx.Observable.from(['1','2','3','4','5','6','7','8','9']);

const example = source.mergeMap(function (item) {
     return Rx.Observable.of(item).delay(1000)
  },
  (v, v2) => v2, concurrent);

const subscribe = example.subscribe(val => console.log(val));</script></body>
</html>