{"version":3,"sources":["jsdelivr-header.js","/npm/muxer@1.0.1/dist/muxer.js"],"names":[],"mappings":"AAAA;AACA;AACA;AACA;AACA;AACA;AACA,ACFA,aAEA,OAAO,eAAe,QAAS,aAAc,CAC3C,OAAO,IAET,QAAQ,MAAQ,QAAQ,SAAM,EAE9B,IAAI,SAAW,OAAO,QAAU,SAAU,GAAU,IAAK,IAAI,EAAI,EAAG,EAAI,UAAU,OAAQ,IAAK,CAAE,IAAI,EAAS,UAAU,GAAI,IAAK,IAAI,KAAO,EAAc,OAAO,UAAU,eAAe,KAAK,EAAQ,KAAQ,EAAO,GAAO,EAAO,GAAU,CAAE,OAAO,CAAQ,EAE3P,eAAgb,SAAU,EAAK,GAAK,GAAI,MAAM,QAAQ,GAAQ,OAAO,EAAY,GAAI,OAAO,YAAY,OAAO,GAAQ,OAAxf,SAAuB,EAAK,GAAK,IAAI,EAAO,GAAQ,GAAK,EAAU,GAAK,EAAW,OAAK,EAAW,IAAM,IAAK,IAAiC,EAA7B,EAAK,EAAI,OAAO,cAAmB,GAAM,EAAK,EAAG,QAAQ,QAAoB,EAAK,KAAK,EAAG,QAAY,GAAK,EAAK,SAAW,GAA3D,GAAK,GAAkE,CAAE,MAAO,GAAO,GAAK,EAAM,EAAK,CAAK,CAAE,QAAU,KAAW,GAAM,EAAW,QAAG,EAAW,QAAK,CAAE,QAAU,GAAI,EAAI,MAAM,CAAI,CAAE,CAAE,OAAO,CAAM,CAAuH,CAAc,EAAK,GAAa,MAAM,IAAI,UAAU,uDAA2D,EAE7oB,IAAM,QAAQ,MAElB,SAAS,gBAAgB,EAAK,EAAK,GAAiK,OAApJ,KAAO,EAAO,OAAO,eAAe,EAAK,EAAK,CAAE,MAAO,EAAO,YAAY,EAAM,cAAc,EAAM,UAAU,IAAkB,EAAI,GAAO,EAAgB,CAAK,CAEhN,IAAI,MAAQ,SAAe,GACzB,OAAO,SAAU,GACf,MAAO,CAAC,EAAG,EACb,CACF,EACI,aAAe,SAAsB,GACvC,OAAO,SAAU,GACf,OAAO,EAAQ,GAAK,IAAI,MAAM,GAChC,CACF,EACI,MAAQ,SAAe,GACzB,OAAO,SAAU,GAIf,OAHY,eAAe,EAAM,GAEhB,KACD,CAClB,CACF,EACI,MAAQ,SAAe,GACzB,OAAO,EAAE,EACX,EACI,QAAU,SAAiB,GAC7B,OAAO,SAAU,GACf,IAEI,EAFQ,eAAe,EAAO,GAElB,GAChB,OAA8B,IAAvB,EAAK,QAAQ,EACtB,CACF,EAQI,IAAM,QAAQ,IAAM,SAAa,GACnC,IAAI,EAAO,OAAO,KAAK,GACvB,OAAO,IAAI,WAAW,MAAM,EAAK,IAAI,aAAa,IACpD,EASI,MAAQ,QAAQ,MAAQ,SAAe,GACzC,IAAK,IAAI,EAAO,UAAU,OAAQ,EAAO,MAAM,EAAO,EAAI,EAAO,EAAI,GAAI,EAAQ,EAAG,EAAQ,EAAM,IAChG,EAAK,EAAQ,GAAK,UAAU,GAG9B,IAKI,EAAQ,EAAQ,OAAO,QAAQ,IAAO,IAAI,OAE9C,MAAO,CADM,EAAK,QANC,SAAsB,EAAQ,GAC/C,IAAI,EAAK,EAAQ,OAAO,MAAM,IAAM,IAAI,OACxC,OAAO,SAAS,CAAC,EAAG,EAAQ,gBAAgB,CAAC,EAAG,EAAK,GACvD,GAGuC,CAAC,GACxB,EAClB","file":"/npm/muxer@1.0.1/dist/muxer.js","sourceRoot":"","sourcesContent":["/**\n * Minified by jsDelivr using Terser v5.39.0.\n * Original file: /npm/muxer@1.0.1/dist/muxer.js\n *\n * Do NOT use SRI with dynamically generated files! More information: https://www.jsdelivr.com/using-sri-with-dynamic-files\n */\n","/**\n * Created by tushar.mathur on 26/05/16.\n */\n\n'use strict';\n\nObject.defineProperty(exports, \"__esModule\", {\n  value: true\n});\nexports.demux = exports.mux = undefined;\n\nvar _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };\n\nvar _slicedToArray = function () { function sliceIterator(arr, i) { var _arr = []; var _n = true; var _d = false; var _e = undefined; try { for (var _i = arr[Symbol.iterator](), _s; !(_n = (_s = _i.next()).done); _n = true) { _arr.push(_s.value); if (i && _arr.length === i) break; } } catch (err) { _d = true; _e = err; } finally { try { if (!_n && _i[\"return\"]) _i[\"return\"](); } finally { if (_d) throw _e; } } return _arr; } return function (arr, i) { if (Array.isArray(arr)) { return arr; } else if (Symbol.iterator in Object(arr)) { return sliceIterator(arr, i); } else { throw new TypeError(\"Invalid attempt to destructure non-iterable instance\"); } }; }();\n\nvar _rx = require('rx');\n\nfunction _defineProperty(obj, key, value) { if (key in obj) { Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true }); } else { obj[key] = value; } return obj; }\n\nvar tuple = function tuple(a) {\n  return function (b) {\n    return [a, b];\n  };\n};\nvar createStream = function createStream(sources) {\n  return function (key) {\n    return sources[key].map(tuple(key));\n  };\n};\nvar match = function match(key) {\n  return function (_ref) {\n    var _ref2 = _slicedToArray(_ref, 1);\n\n    var _key = _ref2[0];\n    return _key === key;\n  };\n};\nvar first = function first(x) {\n  return x[1];\n};\nvar noMatch = function noMatch(keys) {\n  return function (_ref3) {\n    var _ref4 = _slicedToArray(_ref3, 1);\n\n    var key = _ref4[0];\n    return keys.indexOf(key) === -1;\n  };\n};\n\n/**\n * Creates a multiplexed stream from all the input streams\n * @function\n * @param {Object} sources - Dictionary of source streams.\n * @returns {external:Observable} Multiplexed stream\n */\nvar mux = exports.mux = function mux(sources) {\n  var keys = Object.keys(sources);\n  return _rx.Observable.merge(keys.map(createStream(sources)));\n};\n\n/**\n * De-multiplexes the source stream\n * @function\n * @param {external:Observable} source$ - Input multiplexed stream\n * @param {...String} keys - Map of source streams\n * @returns {Array} Tuple of the selected streams and the rest of them\n */\nvar demux = exports.demux = function demux(source$) {\n  for (var _len = arguments.length, keys = Array(_len > 1 ? _len - 1 : 0), _key2 = 1; _key2 < _len; _key2++) {\n    keys[_key2 - 1] = arguments[_key2];\n  }\n\n  var createSource = function createSource(source, key) {\n    var t$ = source$.filter(match(key)).map(first);\n    return _extends({}, source, _defineProperty({}, key, t$));\n  };\n\n  var rest$ = source$.filter(noMatch(keys)).map(first);\n  var source = keys.reduce(createSource, {});\n  return [source, rest$];\n};\n\n/**\n * An observable is an interface that provides a generalized mechanism for push-based notification,\n * also known as observer design pattern.\n * @external Observable\n * @see {@link https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/observable.md RxJS Observable}\n */"]}