Skip to content

Instantly share code, notes, and snippets.

/index.html

Created August 11, 2016 18:33
Show Gist options
  • Save anonymous/e2ee7168e27a4108dfce8e7a1cf9a602 to your computer and use it in GitHub Desktop.
Save anonymous/e2ee7168e27a4108dfce8e7a1cf9a602 to your computer and use it in GitHub Desktop.
Download ZIP
RxJS 5 Operators // source http://jsbin.com/gafede
Raw
index.html
<!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/[email protected]/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>
Raw
jsbin.gafede.js
"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=
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment