{"version":3,"sources":["jsdelivr-header.js","/npm/react-redux-stream@0.2.1/lib/index.js"],"names":[],"mappings":"AAAA;AACA;AACA;AACA;AACA;AACA;AACA,ACNA,aAEA,OAAO,eAAe,QAAS,aAAc,CAC3C,OAAO,IAET,QAAQ,QAAU,OAElB,IAAI,kBAAoB,QAAQ,4BAE5B,mBAAqB,uBAAuB,mBAE5C,cAAgB,QAAQ,wBAExB,eAAiB,uBAAuB,eAExC,QAAU,QAAQ,kBAElB,OAAS,wBAAwB,SAErC,SAAS,wBAAwB,GAAO,GAAI,GAAO,EAAI,WAAc,OAAO,EAAc,IAAI,EAAS,CAAC,EAAG,GAAW,MAAP,EAAe,IAAK,IAAI,KAAO,EAAW,OAAO,UAAU,eAAe,KAAK,EAAK,KAAM,EAAO,GAAO,EAAI,IAAgC,OAAtB,EAAO,QAAU,EAAY,CAAU,CAE5Q,SAAS,uBAAuB,GAAO,OAAO,GAAO,EAAI,WAAa,EAAM,CAAE,QAAS,EAAO,CAE9F,IAAI,OAAS,QAAQ,QAAQ,SAM7B,SAAS,OAAO,EAAW,GACzB,IAAI,EAAgB,UAAU,OAAS,QAAsB,IAAjB,UAAU,GAAmB,UAAU,GAAK,CAAC,EAGrF,GADO,UAAU,OAAS,QAAsB,IAAjB,UAAU,GAAmB,UAAU,GAAK,CAAC,GACxD,QACpB,OAA2B,IAAjB,GAAqC,EAEnD,OAAO,MAAM,EAAW,2CACxB,OAAO,MAAM,EAAe,iDAE5B,IAAI,EAAO,CAAE,QAAS,GAElB,GAAa,EAAI,mBAAmB,SAAS,EAAW,EAAe,GAEvE,GAAa,EAoBjB,MAAO,CAAE,OAnBT,SAAgB,GACd,EAAW,OAAO,GAAG,MACrB,GAAa,EAEb,IAAI,EAAU,EAAW,SACrB,EAAS,EAAc,GAC3B,OAAO,MAAM,GACb,EAAO,OAAO,GAAG,WAAW,UAE5B,IAAI,GAAc,EAAI,eAAe,SAAS,EAAO,EAAQ,EAAW,IAAK,GAO7E,OALA,WACE,IACA,IACA,GAAa,CACf,CAEF,EAGE,QAAS,EAAW,QACpB,WAAI,GACF,OAAO,EAAW,SACpB,EAEJ","file":"/npm/react-redux-stream@0.2.1/lib/index.js","sourceRoot":"","sourcesContent":["/**\n * Minified by jsDelivr using Terser v5.39.0.\n * Original file: /npm/react-redux-stream@0.2.1/lib/index.js\n *\n * Do NOT use SRI with dynamically generated files! More information: https://www.jsdelivr.com/using-sri-with-dynamic-files\n */\n","'use strict';\n\nObject.defineProperty(exports, \"__esModule\", {\n  value: true\n});\nexports.default = Stream;\n\nvar _createPropStream = require('./utils/createPropStream');\n\nvar _createPropStream2 = _interopRequireDefault(_createPropStream);\n\nvar _observeStore = require('./utils/observeStore');\n\nvar _observeStore2 = _interopRequireDefault(_observeStore);\n\nvar _define = require('./utils/define');\n\nvar define = _interopRequireWildcard(_define);\n\nfunction _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) newObj[key] = obj[key]; } } newObj.default = obj; return newObj; } }\n\nfunction _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }\n\nvar should = require('chai').should();\n\n/**\r\n * Creates a streaming context that updates a target context that\r\n * can be attached to a store and streamed to one or more contexts\r\n */\nfunction Stream(streamKey, storeSelector) {\n  var sharedContext = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : {};\n\n  var _ref = arguments.length > 3 && arguments[3] !== undefined ? arguments[3] : {},\n      _ref$verbose = _ref.verbose,\n      verbose = _ref$verbose === undefined ? false : _ref$verbose;\n\n  should.exist(streamKey, 'must specify a key to stream to context');\n  should.exist(storeSelector, 'must specify a storeSelector factory function');\n\n  var opts = { verbose: verbose };\n\n  var propStream = (0, _createPropStream2.default)(streamKey, sharedContext, opts);\n\n  var isAttached = false;\n  function attach(store) {\n    isAttached.should.be.false;\n    isAttached = true;\n\n    var dispose = propStream.listen();\n    var select = storeSelector(store);\n    should.exist(select);\n    select.should.be.instanceof(Function);\n\n    var unsubscribe = (0, _observeStore2.default)(store, select, propStream.set, opts);\n\n    function detach() {\n      unsubscribe();\n      dispose();\n      isAttached = false;\n    }\n    return detach;\n  }\n\n  return { attach: attach,\n    context: propStream.context,\n    get current() {\n      return propStream.current();\n    }\n  };\n}"]}