diff --git a/dist/redux-saga.js b/dist/redux-saga.js index da7f858c7..30ea74edd 100644 --- a/dist/redux-saga.js +++ b/dist/redux-saga.js @@ -70,7 +70,7 @@ return /******/ (function(modules) { // webpackBootstrap } }); - var _channel = __webpack_require__(2); + var _channel = __webpack_require__(3); Object.defineProperty(exports, 'END', { enumerable: true, @@ -91,7 +91,7 @@ return /******/ (function(modules) { // webpackBootstrap } }); - var _buffers = __webpack_require__(3); + var _buffers = __webpack_require__(2); Object.defineProperty(exports, 'buffers', { enumerable: true, @@ -171,6 +171,7 @@ return /******/ (function(modules) { // webpackBootstrap var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function (obj) { return typeof obj; } : function (obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; exports.check = check; + exports.hasOwn = hasOwn; exports.remove = remove; exports.deferred = deferred; exports.arrayOfDeffered = arrayOfDeffered; @@ -213,6 +214,11 @@ return /******/ (function(modules) { // webpackBootstrap } } + var hasOwnProperty = Object.prototype.hasOwnProperty; + function hasOwn(object, property) { + return is.notUndef(object) && hasOwnProperty.call(object, property); + } + var is = exports.is = { undef: function undef(v) { return v === null || v === undefined; @@ -250,6 +256,9 @@ return /******/ (function(modules) { // webpackBootstrap }, helper: function helper(it) { return it && it[HELPER]; + }, + stringableFunc: function stringableFunc(f) { + return is.func(f) && hasOwn(f, 'toString'); } }; @@ -393,6 +402,119 @@ return /******/ (function(modules) { // webpackBootstrap 'use strict'; + Object.defineProperty(exports, "__esModule", { + value: true + }); + exports.buffers = exports.BUFFER_OVERFLOW = undefined; + + var _utils = __webpack_require__(1); + + var BUFFER_OVERFLOW = exports.BUFFER_OVERFLOW = 'Channel\'s Buffer overflow!'; + + var ON_OVERFLOW_THROW = 1; + var ON_OVERFLOW_DROP = 2; + var ON_OVERFLOW_SLIDE = 3; + var ON_OVERFLOW_EXPAND = 4; + + var zeroBuffer = { isEmpty: _utils.kTrue, put: _utils.noop, take: _utils.noop }; + + function ringBuffer() { + var limit = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : 10; + var overflowAction = arguments[1]; + + var arr = new Array(limit); + var length = 0; + var pushIndex = 0; + var popIndex = 0; + + var push = function push(it) { + arr[pushIndex] = it; + pushIndex = (pushIndex + 1) % limit; + length++; + }; + + var take = function take() { + if (length != 0) { + var it = arr[popIndex]; + arr[popIndex] = null; + length--; + popIndex = (popIndex + 1) % limit; + return it; + } + }; + + var flush = function flush() { + var items = []; + while (length) { + items.push(take()); + } + return items; + }; + + return { + isEmpty: function isEmpty() { + return length == 0; + }, + put: function put(it) { + if (length < limit) { + push(it); + } else { + var doubledLimit = void 0; + switch (overflowAction) { + case ON_OVERFLOW_THROW: + throw new Error(BUFFER_OVERFLOW); + case ON_OVERFLOW_SLIDE: + arr[pushIndex] = it; + pushIndex = (pushIndex + 1) % limit; + popIndex = pushIndex; + break; + case ON_OVERFLOW_EXPAND: + doubledLimit = 2 * limit; + + arr = flush(); + + length = arr.length; + pushIndex = arr.length; + popIndex = 0; + + arr.length = doubledLimit; + limit = doubledLimit; + + push(it); + break; + default: + // DROP + } + } + }, + take: take, flush: flush + }; + } + + var buffers = exports.buffers = { + none: function none() { + return zeroBuffer; + }, + fixed: function fixed(limit) { + return ringBuffer(limit, ON_OVERFLOW_THROW); + }, + dropping: function dropping(limit) { + return ringBuffer(limit, ON_OVERFLOW_DROP); + }, + sliding: function sliding(limit) { + return ringBuffer(limit, ON_OVERFLOW_SLIDE); + }, + expanding: function expanding(initialSize) { + return ringBuffer(initialSize, ON_OVERFLOW_EXPAND); + } + }; + +/***/ }, +/* 3 */ +/***/ function(module, exports, __webpack_require__) { + + 'use strict'; + Object.defineProperty(exports, "__esModule", { value: true }); @@ -407,7 +529,7 @@ return /******/ (function(modules) { // webpackBootstrap var _utils = __webpack_require__(1); - var _buffers = __webpack_require__(3); + var _buffers = __webpack_require__(2); var _scheduler = __webpack_require__(7); @@ -596,119 +718,6 @@ return /******/ (function(modules) { // webpackBootstrap }); } -/***/ }, -/* 3 */ -/***/ function(module, exports, __webpack_require__) { - - 'use strict'; - - Object.defineProperty(exports, "__esModule", { - value: true - }); - exports.buffers = exports.BUFFER_OVERFLOW = undefined; - - var _utils = __webpack_require__(1); - - var BUFFER_OVERFLOW = exports.BUFFER_OVERFLOW = 'Channel\'s Buffer overflow!'; - - var ON_OVERFLOW_THROW = 1; - var ON_OVERFLOW_DROP = 2; - var ON_OVERFLOW_SLIDE = 3; - var ON_OVERFLOW_EXPAND = 4; - - var zeroBuffer = { isEmpty: _utils.kTrue, put: _utils.noop, take: _utils.noop }; - - function ringBuffer() { - var limit = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : 10; - var overflowAction = arguments[1]; - - var arr = new Array(limit); - var length = 0; - var pushIndex = 0; - var popIndex = 0; - - var push = function push(it) { - arr[pushIndex] = it; - pushIndex = (pushIndex + 1) % limit; - length++; - }; - - var take = function take() { - if (length != 0) { - var it = arr[popIndex]; - arr[popIndex] = null; - length--; - popIndex = (popIndex + 1) % limit; - return it; - } - }; - - var flush = function flush() { - var items = []; - while (length) { - items.push(take()); - } - return items; - }; - - return { - isEmpty: function isEmpty() { - return length == 0; - }, - put: function put(it) { - if (length < limit) { - push(it); - } else { - var doubledLimit = void 0; - switch (overflowAction) { - case ON_OVERFLOW_THROW: - throw new Error(BUFFER_OVERFLOW); - case ON_OVERFLOW_SLIDE: - arr[pushIndex] = it; - pushIndex = (pushIndex + 1) % limit; - popIndex = pushIndex; - break; - case ON_OVERFLOW_EXPAND: - doubledLimit = 2 * limit; - - arr = flush(); - - length = arr.length; - pushIndex = arr.length; - popIndex = 0; - - arr.length = doubledLimit; - limit = doubledLimit; - - push(it); - break; - default: - // DROP - } - } - }, - take: take, flush: flush - }; - } - - var buffers = exports.buffers = { - none: function none() { - return zeroBuffer; - }, - fixed: function fixed(limit) { - return ringBuffer(limit, ON_OVERFLOW_THROW); - }, - dropping: function dropping(limit) { - return ringBuffer(limit, ON_OVERFLOW_DROP); - }, - sliding: function sliding(limit) { - return ringBuffer(limit, ON_OVERFLOW_SLIDE); - }, - expanding: function expanding(initialSize) { - return ringBuffer(initialSize, ON_OVERFLOW_EXPAND); - } - }; - /***/ }, /* 4 */ /***/ function(module, exports, __webpack_require__) { @@ -1002,9 +1011,9 @@ return /******/ (function(modules) { // webpackBootstrap var _io = __webpack_require__(4); - var _channel = __webpack_require__(2); + var _channel = __webpack_require__(3); - var _buffers = __webpack_require__(3); + var _buffers = __webpack_require__(2); function _defineEnumerableProperties(obj, descs) { for (var key in descs) { var desc = descs[key]; desc.configurable = desc.enumerable = true; if ("value" in desc) desc.writable = true; Object.defineProperty(obj, key, desc); } return obj; } @@ -1031,7 +1040,7 @@ return /******/ (function(modules) { // webpackBootstrap }, default: function _default(pattern) { return function (input) { - return input.type === pattern; + return input.type === String(pattern); }; }, array: function array(patterns) { @@ -1049,7 +1058,7 @@ return /******/ (function(modules) { // webpackBootstrap }; function matcher(pattern) { - return (pattern === '*' ? matchers.wildcard : _utils.is.array(pattern) ? matchers.array : _utils.is.func(pattern) ? matchers.predicate : matchers.default)(pattern); + return (pattern === '*' ? matchers.wildcard : _utils.is.array(pattern) ? matchers.array : _utils.is.stringableFunc(pattern) ? matchers.default : _utils.is.func(pattern) ? matchers.predicate : matchers.default)(pattern); } /** @@ -1062,7 +1071,7 @@ return /******/ (function(modules) { // webpackBootstrap linear execution tree in sequential (non parallel) programming) A parent tasks has the following semantics - - It completes iff all its forks either complete or all cancelled + - It completes if all its forks either complete or all cancelled - If it's cancelled, all forks are cancelled as well - It aborts if any uncaught error bubbles up from forks - If it completes, the return value is the one returned by the main task @@ -1274,7 +1283,7 @@ return /******/ (function(modules) { // webpackBootstrap result = iterator.throw(arg); } else if (arg === TASK_CANCEL) { /** - getting TASK_CANCEL autoamtically cancels the main task + getting TASK_CANCEL automatically cancels the main task We can get this value here - By cancelling the parent task manually - By joining a Cancelled task @@ -1738,13 +1747,13 @@ return /******/ (function(modules) { // webpackBootstrap exports.takeLatestHelper = takeLatestHelper; exports.throttleHelper = throttleHelper; - var _channel = __webpack_require__(2); + var _channel = __webpack_require__(3); var _utils = __webpack_require__(1); var _io = __webpack_require__(4); - var _buffers = __webpack_require__(3); + var _buffers = __webpack_require__(2); var done = { done: true, value: undefined }; var qEnd = {}; @@ -2106,7 +2115,7 @@ return /******/ (function(modules) { // webpackBootstrap var _proc2 = _interopRequireDefault(_proc); - var _channel = __webpack_require__(2); + var _channel = __webpack_require__(3); function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } @@ -2225,7 +2234,8 @@ return /******/ (function(modules) { // webpackBootstrap dispatch = _ref.dispatch, getState = _ref.getState, sagaMonitor = _ref.sagaMonitor, - logger = _ref.logger; + logger = _ref.logger, + onError = _ref.onError; (0, _utils.check)(iterator, _utils.is.iterator, "runSaga must be called on an iterator"); @@ -2235,7 +2245,7 @@ return /******/ (function(modules) { // webpackBootstrap dispatch = (0, _utils.wrapSagaDispatch)(dispatch); sagaMonitor.effectTriggered({ effectId: effectId, root: true, parentEffectId: 0, effect: { root: true, saga: iterator, args: [] } }); } - var task = (0, _proc2.default)(iterator, subscribe, dispatch, getState, { sagaMonitor: sagaMonitor, logger: logger }, effectId, iterator.name); + var task = (0, _proc2.default)(iterator, subscribe, dispatch, getState, { sagaMonitor: sagaMonitor, logger: logger, onError: onError }, effectId, iterator.name); if (sagaMonitor) { sagaMonitor.effectResolved(effectId, task); @@ -2308,12 +2318,12 @@ return /******/ (function(modules) { // webpackBootstrap } }); - var _channel = __webpack_require__(2); + var _proc = __webpack_require__(5); Object.defineProperty(exports, 'CHANNEL_END', { enumerable: true, get: function get() { - return _channel.CHANNEL_END; + return _proc.CHANNEL_END; } }); diff --git a/dist/redux-saga.min.js b/dist/redux-saga.min.js index a60b38b1d..7fd348dcc 100644 --- a/dist/redux-saga.min.js +++ b/dist/redux-saga.min.js @@ -1 +1 @@ -!function(e,n){"object"==typeof exports&&"object"==typeof module?module.exports=n():"function"==typeof define&&define.amd?define([],n):"object"==typeof exports?exports.ReduxSaga=n():e.ReduxSaga=n()}(this,function(){return function(e){function n(r){if(t[r])return t[r].exports;var o=t[r]={exports:{},id:r,loaded:!1};return e[r].call(o.exports,o,o.exports,n),o.loaded=!0,o.exports}var t={};return n.m=e,n.c=t,n.p="",n(0)}([function(e,n,t){"use strict";function r(e){if(e&&e.__esModule)return e;var n={};if(null!=e)for(var t in e)Object.prototype.hasOwnProperty.call(e,t)&&(n[t]=e[t]);return n.default=e,n}function o(e){return e&&e.__esModule?e:{"default":e}}Object.defineProperty(n,"__esModule",{value:!0}),n.utils=n.effects=n.CANCEL=n.delay=n.throttle=n.takeLatest=n.takeEvery=n.buffers=n.channel=n.eventChannel=n.END=n.runSaga=void 0;var a=t(10);Object.defineProperty(n,"runSaga",{enumerable:!0,get:function(){return a.runSaga}});var u=t(2);Object.defineProperty(n,"END",{enumerable:!0,get:function(){return u.END}}),Object.defineProperty(n,"eventChannel",{enumerable:!0,get:function(){return u.eventChannel}}),Object.defineProperty(n,"channel",{enumerable:!0,get:function(){return u.channel}});var i=t(3);Object.defineProperty(n,"buffers",{enumerable:!0,get:function(){return i.buffers}});var c=t(6);Object.defineProperty(n,"takeEvery",{enumerable:!0,get:function(){return c.takeEvery}}),Object.defineProperty(n,"takeLatest",{enumerable:!0,get:function(){return c.takeLatest}}),Object.defineProperty(n,"throttle",{enumerable:!0,get:function(){return c.throttle}});var f=t(1);Object.defineProperty(n,"delay",{enumerable:!0,get:function(){return f.delay}}),Object.defineProperty(n,"CANCEL",{enumerable:!0,get:function(){return f.CANCEL}});var l=t(9),s=o(l),d=t(8),p=r(d),v=t(11),h=r(v);n.default=s.default,n.effects=p,n.utils=h},function(e,n,t){"use strict";function r(e,n,t){return n in e?Object.defineProperty(e,n,{value:t,enumerable:!0,configurable:!0,writable:!0}):e[n]=t,e}function o(e,n,t){if(!n(e))throw d("error","uncaught at check",t),new Error(t)}function a(e,n){var t=e.indexOf(n);t>=0&&e.splice(t,1)}function u(){var e=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{},n=h({},e),t=new Promise(function(e,t){n.resolve=e,n.reject=t});return n.promise=t,n}function i(e){for(var n=[],t=0;t1&&void 0!==arguments[1])||arguments[1],t=void 0,r=new Promise(function(r){t=setTimeout(function(){return r(n)},e)});return r[E]=function(){return clearTimeout(t)},r}function f(){var e,n=!0,t=void 0,o=void 0;return e={},r(e,b,!0),r(e,"isRunning",function(){return n}),r(e,"result",function(){return t}),r(e,"error",function(){return o}),r(e,"setRunning",function(e){return n=e}),r(e,"setResult",function(e){return t=e}),r(e,"setError",function(e){return o=e}),e}function l(){var e=arguments.length>0&&void 0!==arguments[0]?arguments[0]:0;return function(){return++e}}function s(e){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:A,t=arguments.length>2&&void 0!==arguments[2]?arguments[2]:"",r=arguments[3],o={name:t,next:e,"throw":n,"return":w};return r&&(o[m]=!0),"undefined"!=typeof Symbol&&(o[Symbol.iterator]=function(){return o}),o}function d(e,n){var t=arguments.length>2&&void 0!==arguments[2]?arguments[2]:"";"undefined"==typeof window?console.log("redux-saga "+e+": "+n+"\n"+(t&&t.stack||t)):console[e](n,t)}function p(e,n){return function(){return _&&d("warn",n),e.apply(void 0,arguments)}}function v(e){return function(n){var t=Object.defineProperty(n,k,{value:!0});return e(t)}}Object.defineProperty(n,"__esModule",{value:!0});var h=Object.assign||function(e){for(var n=1;n0&&void 0!==arguments[0]?arguments[0]:f.buffers.fixed(),u=!1,i=[];return(0,c.check)(a,c.is.buffer,v),{take:t,put:n,flush:r,close:o,get __takers__(){return i},get __closed__(){return u}}}function a(e){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:f.buffers.none(),t=arguments[2];arguments.length>2&&(0,c.check)(t,c.is.func,"Invalid match function passed to eventChannel");var r=o(n),a=e(function(e){return p(e)?void r.close():void(t&&!t(e)||r.put(e))});if(!c.is.func(a))throw new Error("in eventChannel: subscribe should return a function to unsubscribe");return{take:r.take,flush:r.flush,close:function(){r.__closed__||(r.close(),a())}}}function u(e){var n=a(function(n){return e(function(e){return e[c.SAGA_ACTION]?void n(e):void(0,l.asap)(function(){return n(e)})})});return i({},n,{take:function(e,t){arguments.length>1&&((0,c.check)(t,c.is.func,"channel.take's matcher argument must be a function"),e[c.MATCH]=t),n.take(e)}})}Object.defineProperty(n,"__esModule",{value:!0}),n.UNDEFINED_INPUT_ERROR=n.INVALID_BUFFER=n.isEnd=n.END=void 0;var i=Object.assign||function(e){for(var n=1;n0&&void 0!==arguments[0]?arguments[0]:10,n=arguments[1],t=new Array(e),r=0,o=0,i=0,l=function(n){t[o]=n,o=(o+1)%e,r++},s=function(){if(0!=r){var n=t[i];return t[i]=null,r--,i=(i+1)%e,n}},d=function(){for(var e=[];r;)e.push(s());return e};return{isEmpty:function(){return 0==r},put:function(s){if(r0&&void 0!==arguments[0]?arguments[0]:"*";if(arguments.length&&(0,_.check)(arguments[0],_.is.notUndef,"take(patternOrChannel): patternOrChannel is undefined"),_.is.pattern(e))return H(w,{pattern:e});if(_.is.channel(e))return H(w,{channel:e});throw new Error("take(patternOrChannel): argument "+String(e)+" is not valid channel or a valid pattern")}function a(e,n){return arguments.length>1?((0,_.check)(e,_.is.notUndef,"put(channel, action): argument channel is undefined"),(0,_.check)(e,_.is.channel,"put(channel, action): argument "+e+" is not a valid channel"),(0,_.check)(n,_.is.notUndef,"put(channel, action): argument action is undefined")):((0,_.check)(e,_.is.notUndef,"put(action): argument action is undefined"),n=e,e=null),H(C,{channel:e,action:n})}function u(e){return H(P,e)}function i(e,n,t){(0,_.check)(n,_.is.notUndef,e+": argument fn is undefined");var r=null;if(_.is.array(n)){var o=n,a=O(o,2);r=a[0],n=a[1]}else if(n.fn){var u=n;r=u.context,n=u.fn}return(0,_.check)(n,_.is.func,e+": argument "+n+" is not a function"),{context:r,fn:n,args:t}}function c(e){for(var n=arguments.length,t=Array(n>1?n-1:0),r=1;r2&&void 0!==arguments[2]?arguments[2]:[];return H(T,i("apply",{context:e,fn:n},t))}function l(e){for(var n=arguments.length,t=Array(n>1?n-1:0),r=1;r1?n-1:0),r=1;r1?n-1:0),r=1;r1?n-1:0),r=1;r1&&((0,_.check)(n,_.is.notUndef,"actionChannel(pattern, buffer): argument buffer is undefined"),(0,_.check)(n,_.is.buffer,"actionChannel(pattern, buffer): argument "+n+" is not a valid buffer")),H(U,{pattern:e,buffer:n})}function y(){return H(M,{})}function b(e){return(0,_.check)(e,_.is.channel,"flush(channel): argument "+e+" is not valid channel"),H(I,e)}function m(e,n){for(var t=arguments.length,r=Array(t>2?t-2:0),o=2;o2?t-2:0),o=2;o3?r-3:0),a=3;a2&&void 0!==arguments[2]?arguments[2]:"",o=arguments[3],a=(0,l.uid)();V&&V.effectTriggered({effectId:a,parentEffectId:n,label:r,effect:e});var u=void 0;t.cancel=l.noop,o.cancel=function(){if(!u){u=!0;try{t.cancel()}catch(e){z("error","uncaught at "+G,e.message)}t.cancel=l.noop,V&&V.effectCancelled(a)}};var i=void 0;return l.is.promise(e)?O(e,t):l.is.helper(e)?P(m(e),a,t):l.is.iterator(e)?_(e,a,G,t):l.is.array(e)?S(e,a,t):l.is.notUndef(i=d.asEffect.take(e))?j(i,t):l.is.notUndef(i=d.asEffect.put(e))?A(i,t):l.is.notUndef(i=d.asEffect.race(e))?R(i,a,t):l.is.notUndef(i=d.asEffect.call(e))?w(i,a,t):l.is.notUndef(i=d.asEffect.cps(e))?C(i,t):l.is.notUndef(i=d.asEffect.fork(e))?P(i,a,t):l.is.notUndef(i=d.asEffect.join(e))?T(i,t):l.is.notUndef(i=d.asEffect.cancel(e))?N(i,t):l.is.notUndef(i=d.asEffect.select(e))?x(i,t):l.is.notUndef(i=d.asEffect.actionChannel(e))?L(i,t):l.is.notUndef(i=d.asEffect.flush(e))?M(i,t):l.is.notUndef(i=d.asEffect.cancelled(e))?U(i,t):t(e)}function O(e,n){var t=e[l.CANCEL];"function"==typeof t&&(n.cancel=t),e.then(n,function(e){return n(e,!0)})}function _(e,n,t,r){f(e,D,H,q,F,n,t,r)}function j(e,n){var t=e.channel,r=e.pattern,o=e.maybe;t=t||Q;var a=function(e){return e instanceof Error?n(e,!0):n((0,p.isEnd)(e)&&!o?g:e)};try{t.take(a,u(r))}catch(i){return n(i,!0)}n.cancel=a.cancel}function A(e,n){var t=e.channel,r=e.action,o=e.resolve;(0,s.asap)(function(){var e=void 0;try{e=(t?t.put:H)(r)}catch(a){if(t||o)return n(a,!0);z("error","uncaught at "+G,a.stack||a.message||a)}return o&&l.is.promise(e)?void O(e,n):n(e)})}function w(e,n,t){var r=e.context,o=e.fn,a=e.args,u=void 0;try{u=o.apply(r,a)}catch(i){return t(i,!0)}return l.is.promise(u)?O(u,t):l.is.iterator(u)?_(u,n,o.name,t):t(u)}function C(e,n){var t=e.context,r=e.fn,o=e.args;try{!function(){var e=function(e,t){return l.is.undef(e)?n(t):n(e,!0)};r.apply(t,o.concat(e)),e.cancel&&(n.cancel=function(){return e.cancel()})}()}catch(a){return n(a,!0)}}function P(e,n,t){var r=e.context,o=e.fn,a=e.args,u=e.detached,i=c({context:r,fn:o,args:a});try{(0,s.suspend)();var d=f(i,D,H,q,F,n,o.name,u?null:l.noop);u?t(d):i._isRunning?(Z.addTask(d),t(d)):i._error?Z.abort(i._error):t(d)}finally{(0,s.flush)()}}function T(e,n){e.isRunning()?!function(){var t={task:X,cb:n};n.cancel=function(){return(0,l.remove)(e.joiners,t)},e.joiners.push(t)}():e.isAborted()?n(e.error(),!0):n(e.result())}function N(e,n){e.isRunning()&&e.cancel(),n()}function S(e,n,t){function r(){o===u.length&&(a=!0,t(u))}if(!e.length)return t([]);var o=0,a=void 0,u=Array(e.length),i=e.map(function(e,n){var i=function(e,i){a||(i||(0,p.isEnd)(e)||e===g||e===y?(t.cancel(),t(e,i)):(u[n]=e,o++,r()))};return i.cancel=l.noop,i});t.cancel=function(){a||(a=!0,i.forEach(function(e){return e.cancel()}))},e.forEach(function(e,t){return k(e,n,t,i[t])})}function R(e,n,t){var r=void 0,o=Object.keys(e),u={};o.forEach(function(e){var n=function(n,o){r||(o?(t.cancel(),t(n,!0)):(0,p.isEnd)(n)||n===g||n===y||(t.cancel(),r=!0,t(a({},e,n))))};n.cancel=l.noop,u[e]=n}),t.cancel=function(){r||(r=!0,o.forEach(function(e){return u[e].cancel()}))},o.forEach(function(t){r||k(e[t],n,t,u[t])})}function x(e,n){var t=e.selector,r=e.args;try{var a=t.apply(void 0,[q()].concat(o(r)));n(a)}catch(u){n(u,!0)}}function L(e,n){var t=e.pattern,r=e.buffer,o=u(t);o.pattern=t,n((0,p.eventChannel)(D,r||v.buffers.fixed(),o))}function U(e,n){n(!!Y.isCancelled)}function M(e,n){e.flush(n)}function I(e,n,o,u){var i,c,f;return o._deferredEnd=null,c={},a(c,l.TASK,!0),a(c,"id",e),a(c,"name",n),i="done",f={},f[i]=f[i]||{},f[i].get=function(){if(o._deferredEnd)return o._deferredEnd.promise;var e=(0,l.deferred)();return o._deferredEnd=e,o._isRunning||(o._error?e.reject(o._error):e.resolve(o._result)),e.promise},a(c,"cont",u),a(c,"joiners",[]),a(c,"cancel",t),a(c,"isRunning",function(){return o._isRunning}),a(c,"isCancelled",function(){return o._isCancelled}),a(c,"isAborted",function(){return o._isAborted}),a(c,"result",function(){return o._result}),a(c,"error",function(){return o._error}),r(c,f),c}var D=arguments.length>1&&void 0!==arguments[1]?arguments[1]:function(){return l.noop},H=arguments.length>2&&void 0!==arguments[2]?arguments[2]:l.noop,q=arguments.length>3&&void 0!==arguments[3]?arguments[3]:l.noop,F=arguments.length>4&&void 0!==arguments[4]?arguments[4]:{},K=arguments.length>5&&void 0!==arguments[5]?arguments[5]:0,G=arguments.length>6&&void 0!==arguments[6]?arguments[6]:"anonymous",B=arguments[7];(0,l.check)(e,l.is.iterator,h);var V=F.sagaMonitor,W=F.logger,J=F.onError,z=W||l.log,Q=(0,p.stdChannel)(D);b.cancel=l.noop;var X=I(K,G,e,B),Y={name:G,cancel:n,isRunning:!0},Z=i(G,Y,E);return B&&(B.cancel=t),e._isRunning=!0,b(),X}Object.defineProperty(n,"__esModule",{value:!0}),n.TASK_CANCEL=n.CHANNEL_END=n.NOT_ITERATOR_ERROR=void 0,n.default=f;var l=t(1),s=t(7),d=t(4),p=t(2),v=t(3),h=n.NOT_ITERATOR_ERROR="proc first argument (Saga function result) must be an iterator",g=n.CHANNEL_END={toString:function(){return"@@redux-saga/CHANNEL_END"}},y=n.TASK_CANCEL={toString:function(){return"@@redux-saga/TASK_CANCEL"}},b={wildcard:function(){return l.kTrue},"default":function(e){return function(n){return n.type===e}},array:function(e){return function(n){return e.some(function(e){return u(e)(n)})}},predicate:function(e){return function(n){return e(n)}}},m=function(e){return{fn:e}}},function(e,n,t){"use strict";function r(e,n){function t(n,t){if(a===v)return p;if(t)throw a=v,t;o&&o(n);var r=e[a](),u=c(r,3),i=u[0],f=u[1],l=u[2];return a=i,o=l,a===v?p:f}var r=arguments.length>2&&void 0!==arguments[2]?arguments[2]:"iterator",o=void 0,a=n;return(0,l.makeIterator)(t,function(e){return t(null,e)},r,!0)}function o(e){return l.is.channel(e)?"channel":Array.isArray(e)?String(e.map(function(e){return String(e)})):String(e)}function a(e,n){for(var t=arguments.length,a=Array(t>2?t-2:0),u=2;u2?t-2:0),u=2;u3?a-3:0),i=3;i0&&void 0!==arguments[0]?arguments[0]:{},t=void 0,r=n.sagaMonitor;if(r&&(r.effectTriggered=r.effectTriggered||u.noop,r.effectResolved=r.effectResolved||u.noop,r.effectRejected=r.effectRejected||u.noop,r.effectCancelled=r.effectCancelled||u.noop,r.actionDispatched=r.actionDispatched||u.noop),u.is.func(n))throw new Error("Saga middleware no longer accept Generator functions. Use sagaMiddleware.run instead");if(n.logger&&!u.is.func(n.logger))throw new Error("`options.logger` passed to the Saga middleware is not a function!");if(n.onerror&&(u.isDev&&(0,u.log)("warn","`options.onerror` is deprecated. Use `options.onError` instead."),n.onError=n.onerror,delete n.onerror),n.onError&&!u.is.func(n.onError))throw new Error("`options.onError` passed to the Saga middleware is not a function!");if(n.emitter&&!u.is.func(n.emitter))throw new Error("`options.emitter` passed to the Saga middleware is not a function!");return e.run=function(e){for(var n=arguments.length,o=Array(n>1?n-1:0),a=1;a=0&&e.splice(t,1)}function i(){var e=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{},n=g({},e),t=new Promise(function(e,t){n.resolve=e,n.reject=t});return n.promise=t,n}function c(e){for(var n=[],t=0;t1&&void 0!==arguments[1])||arguments[1],t=void 0,r=new Promise(function(r){t=setTimeout(function(){return r(n)},e)});return r[k]=function(){return clearTimeout(t)},r}function l(){var e,n=!0,t=void 0,o=void 0;return e={},r(e,m,!0),r(e,"isRunning",function(){return n}),r(e,"result",function(){return t}),r(e,"error",function(){return o}),r(e,"setRunning",function(e){return n=e}),r(e,"setResult",function(e){return t=e}),r(e,"setError",function(e){return o=e}),e}function s(){var e=arguments.length>0&&void 0!==arguments[0]?arguments[0]:0;return function(){return++e}}function d(e){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:C,t=arguments.length>2&&void 0!==arguments[2]?arguments[2]:"",r=arguments[3],o={name:t,next:e,"throw":n,"return":P};return r&&(o[E]=!0),"undefined"!=typeof Symbol&&(o[Symbol.iterator]=function(){return o}),o}function p(e,n){var t=arguments.length>2&&void 0!==arguments[2]?arguments[2]:"";"undefined"==typeof window?console.log("redux-saga "+e+": "+n+"\n"+(t&&t.stack||t)):console[e](n,t)}function v(e,n){return function(){return _&&p("warn",n),e.apply(void 0,arguments)}}function h(e){return function(n){var t=Object.defineProperty(n,O,{value:!0});return e(t)}}Object.defineProperty(n,"__esModule",{value:!0});var g=Object.assign||function(e){for(var n=1;n0&&void 0!==arguments[0]?arguments[0]:10,n=arguments[1],t=new Array(e),r=0,o=0,i=0,l=function(n){t[o]=n,o=(o+1)%e,r++},s=function(){if(0!=r){var n=t[i];return t[i]=null,r--,i=(i+1)%e,n}},d=function(){for(var e=[];r;)e.push(s());return e};return{isEmpty:function(){return 0==r},put:function(s){if(r0&&void 0!==arguments[0]?arguments[0]:f.buffers.fixed(),u=!1,i=[];return(0,c.check)(a,c.is.buffer,v),{take:t,put:n,flush:r,close:o,get __takers__(){return i},get __closed__(){return u}}}function a(e){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:f.buffers.none(),t=arguments[2];arguments.length>2&&(0,c.check)(t,c.is.func,"Invalid match function passed to eventChannel");var r=o(n),a=e(function(e){return p(e)?void r.close():void(t&&!t(e)||r.put(e))});if(!c.is.func(a))throw new Error("in eventChannel: subscribe should return a function to unsubscribe");return{take:r.take,flush:r.flush,close:function(){r.__closed__||(r.close(),a())}}}function u(e){var n=a(function(n){return e(function(e){return e[c.SAGA_ACTION]?void n(e):void(0,l.asap)(function(){return n(e)})})});return i({},n,{take:function(e,t){arguments.length>1&&((0,c.check)(t,c.is.func,"channel.take's matcher argument must be a function"),e[c.MATCH]=t),n.take(e)}})}Object.defineProperty(n,"__esModule",{value:!0}),n.UNDEFINED_INPUT_ERROR=n.INVALID_BUFFER=n.isEnd=n.END=void 0;var i=Object.assign||function(e){for(var n=1;n0&&void 0!==arguments[0]?arguments[0]:"*";if(arguments.length&&(0,j.check)(arguments[0],j.is.notUndef,"take(patternOrChannel): patternOrChannel is undefined"),j.is.pattern(e))return H(w,{pattern:e});if(j.is.channel(e))return H(w,{channel:e});throw new Error("take(patternOrChannel): argument "+String(e)+" is not valid channel or a valid pattern")}function a(e,n){return arguments.length>1?((0,j.check)(e,j.is.notUndef,"put(channel, action): argument channel is undefined"),(0,j.check)(e,j.is.channel,"put(channel, action): argument "+e+" is not a valid channel"),(0,j.check)(n,j.is.notUndef,"put(channel, action): argument action is undefined")):((0,j.check)(e,j.is.notUndef,"put(action): argument action is undefined"),n=e,e=null),H(C,{channel:e,action:n})}function u(e){return H(P,e)}function i(e,n,t){(0,j.check)(n,j.is.notUndef,e+": argument fn is undefined");var r=null;if(j.is.array(n)){var o=n,a=O(o,2);r=a[0],n=a[1]}else if(n.fn){var u=n;r=u.context,n=u.fn}return(0,j.check)(n,j.is.func,e+": argument "+n+" is not a function"),{context:r,fn:n,args:t}}function c(e){for(var n=arguments.length,t=Array(n>1?n-1:0),r=1;r2&&void 0!==arguments[2]?arguments[2]:[];return H(S,i("apply",{context:e,fn:n},t))}function l(e){for(var n=arguments.length,t=Array(n>1?n-1:0),r=1;r1?n-1:0),r=1;r1?n-1:0),r=1;r1?n-1:0),r=1;r1&&((0,j.check)(n,j.is.notUndef,"actionChannel(pattern, buffer): argument buffer is undefined"),(0,j.check)(n,j.is.buffer,"actionChannel(pattern, buffer): argument "+n+" is not a valid buffer")),H(U,{pattern:e,buffer:n})}function y(){return H(M,{})}function b(e){return(0,j.check)(e,j.is.channel,"flush(channel): argument "+e+" is not valid channel"),H(I,e)}function m(e,n){for(var t=arguments.length,r=Array(t>2?t-2:0),o=2;o2?t-2:0),o=2;o3?r-3:0),a=3;a2&&void 0!==arguments[2]?arguments[2]:"",o=arguments[3],a=(0,l.uid)();V&&V.effectTriggered({effectId:a,parentEffectId:n,label:r,effect:e});var u=void 0;t.cancel=l.noop,o.cancel=function(){if(!u){u=!0;try{t.cancel()}catch(e){z("error","uncaught at "+G,e.message)}t.cancel=l.noop,V&&V.effectCancelled(a)}};var i=void 0;return l.is.promise(e)?O(e,t):l.is.helper(e)?P(m(e),a,t):l.is.iterator(e)?j(e,a,G,t):l.is.array(e)?N(e,a,t):l.is.notUndef(i=d.asEffect.take(e))?_(i,t):l.is.notUndef(i=d.asEffect.put(e))?A(i,t):l.is.notUndef(i=d.asEffect.race(e))?R(i,a,t):l.is.notUndef(i=d.asEffect.call(e))?w(i,a,t):l.is.notUndef(i=d.asEffect.cps(e))?C(i,t):l.is.notUndef(i=d.asEffect.fork(e))?P(i,a,t):l.is.notUndef(i=d.asEffect.join(e))?S(i,t):l.is.notUndef(i=d.asEffect.cancel(e))?T(i,t):l.is.notUndef(i=d.asEffect.select(e))?x(i,t):l.is.notUndef(i=d.asEffect.actionChannel(e))?L(i,t):l.is.notUndef(i=d.asEffect.flush(e))?M(i,t):l.is.notUndef(i=d.asEffect.cancelled(e))?U(i,t):t(e)}function O(e,n){var t=e[l.CANCEL];"function"==typeof t&&(n.cancel=t),e.then(n,function(e){return n(e,!0)})}function j(e,n,t,r){f(e,D,H,q,F,n,t,r)}function _(e,n){var t=e.channel,r=e.pattern,o=e.maybe;t=t||Q;var a=function(e){return e instanceof Error?n(e,!0):n((0,p.isEnd)(e)&&!o?g:e)};try{t.take(a,u(r))}catch(i){return n(i,!0)}n.cancel=a.cancel}function A(e,n){var t=e.channel,r=e.action,o=e.resolve;(0,s.asap)(function(){var e=void 0;try{e=(t?t.put:H)(r)}catch(a){if(t||o)return n(a,!0);z("error","uncaught at "+G,a.stack||a.message||a)}return o&&l.is.promise(e)?void O(e,n):n(e)})}function w(e,n,t){var r=e.context,o=e.fn,a=e.args,u=void 0;try{u=o.apply(r,a)}catch(i){return t(i,!0)}return l.is.promise(u)?O(u,t):l.is.iterator(u)?j(u,n,o.name,t):t(u)}function C(e,n){var t=e.context,r=e.fn,o=e.args;try{!function(){var e=function(e,t){return l.is.undef(e)?n(t):n(e,!0)};r.apply(t,o.concat(e)),e.cancel&&(n.cancel=function(){return e.cancel()})}()}catch(a){return n(a,!0)}}function P(e,n,t){var r=e.context,o=e.fn,a=e.args,u=e.detached,i=c({context:r,fn:o,args:a});try{(0,s.suspend)();var d=f(i,D,H,q,F,n,o.name,u?null:l.noop);u?t(d):i._isRunning?(Z.addTask(d),t(d)):i._error?Z.abort(i._error):t(d)}finally{(0,s.flush)()}}function S(e,n){e.isRunning()?!function(){var t={task:X,cb:n};n.cancel=function(){return(0,l.remove)(e.joiners,t)},e.joiners.push(t)}():e.isAborted()?n(e.error(),!0):n(e.result())}function T(e,n){e.isRunning()&&e.cancel(),n()}function N(e,n,t){function r(){o===u.length&&(a=!0,t(u))}if(!e.length)return t([]);var o=0,a=void 0,u=Array(e.length),i=e.map(function(e,n){var i=function(e,i){a||(i||(0,p.isEnd)(e)||e===g||e===y?(t.cancel(),t(e,i)):(u[n]=e,o++,r()))};return i.cancel=l.noop,i});t.cancel=function(){a||(a=!0,i.forEach(function(e){return e.cancel()}))},e.forEach(function(e,t){return k(e,n,t,i[t])})}function R(e,n,t){var r=void 0,o=Object.keys(e),u={};o.forEach(function(e){var n=function(n,o){r||(o?(t.cancel(),t(n,!0)):(0,p.isEnd)(n)||n===g||n===y||(t.cancel(),r=!0,t(a({},e,n))))};n.cancel=l.noop,u[e]=n}),t.cancel=function(){r||(r=!0,o.forEach(function(e){return u[e].cancel()}))},o.forEach(function(t){r||k(e[t],n,t,u[t])})}function x(e,n){var t=e.selector,r=e.args;try{var a=t.apply(void 0,[q()].concat(o(r)));n(a)}catch(u){n(u,!0)}}function L(e,n){var t=e.pattern,r=e.buffer,o=u(t);o.pattern=t,n((0,p.eventChannel)(D,r||v.buffers.fixed(),o))}function U(e,n){n(!!Y.isCancelled)}function M(e,n){e.flush(n)}function I(e,n,o,u){var i,c,f;return o._deferredEnd=null,c={},a(c,l.TASK,!0),a(c,"id",e),a(c,"name",n),i="done",f={},f[i]=f[i]||{},f[i].get=function(){if(o._deferredEnd)return o._deferredEnd.promise;var e=(0,l.deferred)();return o._deferredEnd=e,o._isRunning||(o._error?e.reject(o._error):e.resolve(o._result)),e.promise},a(c,"cont",u),a(c,"joiners",[]),a(c,"cancel",t),a(c,"isRunning",function(){return o._isRunning}),a(c,"isCancelled",function(){return o._isCancelled}),a(c,"isAborted",function(){return o._isAborted}),a(c,"result",function(){return o._result}),a(c,"error",function(){return o._error}),r(c,f),c}var D=arguments.length>1&&void 0!==arguments[1]?arguments[1]:function(){return l.noop},H=arguments.length>2&&void 0!==arguments[2]?arguments[2]:l.noop,q=arguments.length>3&&void 0!==arguments[3]?arguments[3]:l.noop,F=arguments.length>4&&void 0!==arguments[4]?arguments[4]:{},K=arguments.length>5&&void 0!==arguments[5]?arguments[5]:0,G=arguments.length>6&&void 0!==arguments[6]?arguments[6]:"anonymous",B=arguments[7];(0,l.check)(e,l.is.iterator,h);var V=F.sagaMonitor,W=F.logger,J=F.onError,z=W||l.log,Q=(0,p.stdChannel)(D);b.cancel=l.noop;var X=I(K,G,e,B),Y={name:G,cancel:n,isRunning:!0},Z=i(G,Y,E);return B&&(B.cancel=t),e._isRunning=!0,b(),X}Object.defineProperty(n,"__esModule",{value:!0}),n.TASK_CANCEL=n.CHANNEL_END=n.NOT_ITERATOR_ERROR=void 0,n.default=f;var l=t(1),s=t(7),d=t(4),p=t(3),v=t(2),h=n.NOT_ITERATOR_ERROR="proc first argument (Saga function result) must be an iterator",g=n.CHANNEL_END={toString:function(){return"@@redux-saga/CHANNEL_END"}},y=n.TASK_CANCEL={toString:function(){return"@@redux-saga/TASK_CANCEL"}},b={wildcard:function(){return l.kTrue},"default":function(e){return function(n){return n.type===String(e)}},array:function(e){return function(n){return e.some(function(e){return u(e)(n)})}},predicate:function(e){return function(n){return e(n)}}},m=function(e){return{fn:e}}},function(e,n,t){"use strict";function r(e,n){function t(n,t){if(a===v)return p;if(t)throw a=v,t;o&&o(n);var r=e[a](),u=c(r,3),i=u[0],f=u[1],l=u[2];return a=i,o=l,a===v?p:f}var r=arguments.length>2&&void 0!==arguments[2]?arguments[2]:"iterator",o=void 0,a=n;return(0,l.makeIterator)(t,function(e){return t(null,e)},r,!0)}function o(e){return l.is.channel(e)?"channel":Array.isArray(e)?String(e.map(function(e){return String(e)})):String(e)}function a(e,n){for(var t=arguments.length,a=Array(t>2?t-2:0),u=2;u2?t-2:0),u=2;u3?a-3:0),i=3;i0&&void 0!==arguments[0]?arguments[0]:{},t=void 0,r=n.sagaMonitor;if(r&&(r.effectTriggered=r.effectTriggered||u.noop,r.effectResolved=r.effectResolved||u.noop,r.effectRejected=r.effectRejected||u.noop,r.effectCancelled=r.effectCancelled||u.noop,r.actionDispatched=r.actionDispatched||u.noop),u.is.func(n))throw new Error("Saga middleware no longer accept Generator functions. Use sagaMiddleware.run instead");if(n.logger&&!u.is.func(n.logger))throw new Error("`options.logger` passed to the Saga middleware is not a function!");if(n.onerror&&(u.isDev&&(0,u.log)("warn","`options.onerror` is deprecated. Use `options.onError` instead."),n.onError=n.onerror,delete n.onerror),n.onError&&!u.is.func(n.onError))throw new Error("`options.onError` passed to the Saga middleware is not a function!");if(n.emitter&&!u.is.func(n.emitter))throw new Error("`options.emitter` passed to the Saga middleware is not a function!");return e.run=function(e){for(var n=arguments.length,o=Array(n>1?n-1:0),a=1;a