redux-saga - npm Package Compare versions

Comparing version 0.10.5 to 0.11.0

dist/redux-saga.js

@@ -996,3 +996,3 @@ (function webpackUniversalModuleDefinition(root, factory) {
 	  var getState = arguments.length <= 3 || arguments[3] === undefined ? _utils.noop : arguments[3];
-	  var monitor = arguments[4];
+	  var options = arguments.length <= 4 || arguments[4] === undefined ? {} : arguments[4];
 	  var parentEffectId = arguments.length <= 5 || arguments[5] === undefined ? 0 : arguments[5];
@@ -1004,2 +1004,6 @@ var name = arguments.length <= 6 || arguments[6] === undefined ? 'anonymous' : arguments[6];
 
+	  var sagaMonitor = options.sagaMonitor;
+	  var logger = options.logger;
+
+	  var log = logger || _utils.log;
 	  var stdChannel = (0, _channel.eventChannel)(subscribe);
@@ -1117,3 +1121,3 @@ /**
 	      if (mainTask.isCancelled) {
-	        (0, _utils.log)('error', 'uncaught at ' + name, error.message);
+	        log('error', 'uncaught at ' + name, error.message);
 	      }
@@ -1130,3 +1134,3 @@ mainTask.isMainRunning = false;
 	      if (result === TASK_CANCEL && isDev) {
-	        (0, _utils.log)('info', name + ' has been cancelled', '');
+	        log('info', name + ' has been cancelled', '');
 	      }
@@ -1140,3 +1144,3 @@ iterator._result = result;
 	      if (!task.cont) {
-	        (0, _utils.log)('error', 'uncaught', result.sagaStack || result.stack);
+	        log('error', 'uncaught', result.sagaStack || result.stack);
 	      }
@@ -1159,3 +1163,3 @@ iterator._error = result;
 	    var effectId = nextEffectId();
-	    monitor && monitor.effectTriggered({ effectId: effectId, parentEffectId: parentEffectId, label: label, effect: effect });
+	    sagaMonitor && sagaMonitor.effectTriggered({ effectId: effectId, parentEffectId: parentEffectId, label: label, effect: effect });
 
@@ -1177,4 +1181,4 @@ /**
 	      cb.cancel = _utils.noop; // defensive measure
-	      if (monitor) {
-	        isErr ? monitor.effectRejected(effectId, res) : monitor.effectResolved(effectId, res);
+	      if (sagaMonitor) {
+	        isErr ? sagaMonitor.effectRejected(effectId, res) : sagaMonitor.effectResolved(effectId, res);
 	      }
@@ -1203,7 +1207,7 @@
 	      } catch (err) {
-	        (0, _utils.log)('error', 'uncaught at ' + name, err.message);
+	        log('error', 'uncaught at ' + name, err.message);
 	      }
 	      currCb.cancel = _utils.noop; // defensive measure
 
-	      monitor && monitor.effectCancelled(effectId);
+	      sagaMonitor && sagaMonitor.effectCancelled(effectId);
 	    };
@@ -1244,3 +1248,3 @@
 	  function resolveIterator(iterator, effectId, name, cb) {
-	    proc(iterator, subscribe, dispatch, getState, monitor, effectId, name, cb);
+	    proc(iterator, subscribe, dispatch, getState, options, effectId, name, cb);
 	  }
@@ -1378,3 +1382,3 @@
 	    _asap2.default.suspend();
-	    var task = proc(_iterator, subscribe, dispatch, getState, monitor, effectId, fn.name, detached ? null : _utils.noop);
+	    var task = proc(_iterator, subscribe, dispatch, getState, options, effectId, fn.name, detached ? null : _utils.noop);
 	    if (!detached) {
@@ -1720,2 +1724,6 @@ if (_iterator._isRunning) {
 
+	  if (options.logger && !_utils.is.func(options.logger)) {
+	    throw new Error('`options.logger` passed to the Saga middleware is not a function!');
+	  }
+
 	  function sagaMiddleware(_ref) {
@@ -1733,3 +1741,3 @@ var getState = _ref.getState;
 
-	      return (0, _proc2.default)(saga.apply(undefined, args), sagaEmitter.subscribe, dispatch, getState, options.sagaMonitor, 0, saga.name);
+	      return (0, _proc2.default)(saga.apply(undefined, args), sagaEmitter.subscribe, dispatch, getState, options, 0, saga.name);
 	    }
@@ -1778,6 +1786,8 @@
 
-	function runSaga(iterator, _ref, monitor) {
+	function runSaga(iterator, _ref) {
 	  var subscribe = _ref.subscribe;
 	  var dispatch = _ref.dispatch;
 	  var getState = _ref.getState;
+	  var sagaMonitor = _ref.sagaMonitor;
+	  var logger = _ref.logger;
 
@@ -1787,3 +1797,3 @@
 
-	  return (0, _proc2.default)(iterator, subscribe, dispatch, getState, monitor);
+	  return (0, _proc2.default)(iterator, subscribe, dispatch, getState, { sagaMonitor: sagaMonitor, logger: logger });
 	}
@@ -1790,0 +1800,0 @@

dist/redux-saga.min.js

@@ -1,1 +0,1 @@
-!function(n,e){"object"==typeof exports&&"object"==typeof module?module.exports=e():"function"==typeof define&&define.amd?define([],e):"object"==typeof exports?exports.ReduxSaga=e():n.ReduxSaga=e()}(this,function(){return function(n){function e(r){if(t[r])return t[r].exports;var u=t[r]={exports:{},id:r,loaded:!1};return n[r].call(u.exports,u,u.exports,e),u.loaded=!0,u.exports}var t={};return e.m=n,e.c=t,e.p="",e(0)}([function(n,e,t){"use strict";function r(n){if(n&&n.__esModule)return n;var e={};if(null!=n)for(var t in n)Object.prototype.hasOwnProperty.call(n,t)&&(e[t]=n[t]);return e.default=n,e}function u(n){return n&&n.__esModule?n:{"default":n}}Object.defineProperty(e,"__esModule",{value:!0}),e.utils=e.effects=e.CANCEL=e.delay=e.takeLatest=e.takeEvery=e.buffers=e.channel=e.eventChannel=e.END=e.runSaga=void 0;var o=t(9);Object.defineProperty(e,"runSaga",{enumerable:!0,get:function(){return o.runSaga}});var a=t(2);Object.defineProperty(e,"END",{enumerable:!0,get:function(){return a.END}}),Object.defineProperty(e,"eventChannel",{enumerable:!0,get:function(){return a.eventChannel}}),Object.defineProperty(e,"channel",{enumerable:!0,get:function(){return a.channel}});var i=t(4);Object.defineProperty(e,"buffers",{enumerable:!0,get:function(){return i.buffers}});var c=t(10);Object.defineProperty(e,"takeEvery",{enumerable:!0,get:function(){return c.takeEvery}}),Object.defineProperty(e,"takeLatest",{enumerable:!0,get:function(){return c.takeLatest}});var f=t(1);Object.defineProperty(e,"delay",{enumerable:!0,get:function(){return f.delay}}),Object.defineProperty(e,"CANCEL",{enumerable:!0,get:function(){return f.CANCEL}});var l=t(8),s=u(l),d=t(6),p=r(d),v=t(11),h=r(v);e.default=s.default,e.effects=p,e.utils=h},function(n,e){"use strict";function t(n,e,t){return e in n?Object.defineProperty(n,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):n[e]=t,n}function r(n,e,t){if(!e(n))throw s("error","uncaught at check",t),new Error(t)}function u(n,e){var t=n.indexOf(e);t>=0&&n.splice(t,1)}function o(){var n=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],e=d({},n),t=new Promise(function(n,t){e.resolve=n,e.reject=t});return e.promise=t,e}function a(n){for(var e=[],t=0;n>t;t++)e.push(o());return e}function i(n){var e=arguments.length<=1||void 0===arguments[1]?!0:arguments[1],t=void 0,r=new Promise(function(r){t=setTimeout(function(){return r(e)},n)});return r[g]=function(){return clearTimeout(t)},r}function c(){var n,e=!0,r=void 0,u=void 0;return n={},t(n,h,!0),t(n,"isRunning",function(){return e}),t(n,"result",function(){return r}),t(n,"error",function(){return u}),t(n,"setRunning",function(n){return e=n}),t(n,"setResult",function(n){return r=n}),t(n,"setError",function(n){return u=n}),n}function f(){var n=arguments.length<=0||void 0===arguments[0]?0:arguments[0];return function(){return++n}}function l(n){var e=arguments.length<=1||void 0===arguments[1]?m:arguments[1],t=arguments.length<=2||void 0===arguments[2]?"":arguments[2],r={name:t,next:n,"throw":e};return"undefined"!=typeof Symbol&&(r[Symbol.iterator]=function(){return r}),r}function s(n,e,t){"undefined"==typeof window?console.log("redux-saga "+n+": "+e+"\n"+(t&&t.stack||t)):console[n].call(console,e,t)}Object.defineProperty(e,"__esModule",{value:!0});var d=Object.assign||function(n){for(var e=1;e<arguments.length;e++){var t=arguments[e];for(var r in t)Object.prototype.hasOwnProperty.call(t,r)&&(n[r]=t[r])}return n},p="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(n){return typeof n}:function(n){return n&&"function"==typeof Symbol&&n.constructor===Symbol?"symbol":typeof n};e.check=r,e.remove=u,e.deferred=o,e.arrayOfDeffered=a,e.delay=i,e.createMockTask=c,e.autoInc=f,e.makeIterator=l,e.log=s;var v=e.sym=function(n){return"@@redux-saga/"+n},h=e.TASK=v("TASK"),g=(e.MATCH=v("MATCH"),e.CANCEL=v("cancelPromise")),y=e.konst=function(n){return function(){return n}},b=(e.kTrue=y(!0),e.kFalse=y(!1),e.noop=function(){},e.ident=function(n){return n},e.is={undef:function(n){return null===n||void 0===n},notUndef:function(n){return null!==n&&void 0!==n},func:function(n){return"function"==typeof n},number:function(n){return"number"==typeof n},array:Array.isArray,promise:function(n){return n&&b.func(n.then)},iterator:function(n){return n&&b.func(n.next)&&b.func(n.throw)},task:function(n){return n&&n[h]},take:function(n){return n&&b.func(n.take)},put:function(n){return n&&b.func(n.put)},observable:function(n){return n&&b.func(n.subscribe)},buffer:function(n){return n&&b.func(n.isEmpty)&&b.func(n.take)&&b.func(n.put)},pattern:function(n){return n&&("string"==typeof n||"symbol"===("undefined"==typeof n?"undefined":p(n))||b.func(n)||b.array(n))}}),m=function(n){throw n};e.internalErr=function(n){return new Error("\n  redux-saga: Error checking hooks detected an inconsisten state. This is likely a bug\n  in redux-saga code and not yours. Thanks for reporting this in the project's github repo.\n  Error: "+n+"\n")}},function(n,e,t){"use strict";function r(){function n(n){return t.push(n),function(){return(0,a.remove)(t,n)}}function e(n){for(var e=t.slice(),r=0,u=e.length;u>r;r++)e[r](n)}var t=[];return{subscribe:n,emit:e}}function u(n){function e(){if(o&&c.length)throw(0,a.internalErr)("Cannot have a closed channel with pending takers");if(c.length&&!n.isEmpty())throw(0,a.internalErr)("Cannot have pending takers with non empty buffer")}function t(t){if(e(),(0,a.check)(t,a.is.notUndef,d),!o)if(c.length)for(var r=0;r<c.length;r++){var u=c[r];if(!u[a.MATCH]||u[a.MATCH](t))return c.splice(r,1),u(t)}else n.put(t)}function r(t,r){e(),(0,a.check)(t,a.is.func,"channel.take's callback must be a function"),arguments.length>1&&((0,a.check)(r,a.is.func,"channel.take's matcher argument must be a function"),t[a.MATCH]=r),o&&n.isEmpty()?t(f):n.isEmpty()?(c.push(t),t.cancel=function(){return(0,a.remove)(c,t)}):t(n.take())}function u(){if(e(),!o&&(o=!0,c.length)){var n=c;c=[];for(var t=0,r=n.length;r>t;t++)n[t](f);c=[]}}var o=!1,c=[];return arguments.length>0?(0,a.check)(n,a.is.buffer,s):n=i.buffers.fixed(),{take:r,put:t,close:u,get __takers__(){return c},get __closed__(){return o}}}function o(n){var e=arguments.length<=1||void 0===arguments[1]?i.buffers.none():arguments[1],t=arguments[2];arguments.length>2&&(0,a.check)(t,a.is.func,"Invalid match function passed to eventChannel");var r=u(e),o=n(function(n){l(n)?r.close():t&&!t(n)||r.put(n)});return{take:r.take,close:function(){r.__closed__||(r.close(),o())}}}Object.defineProperty(e,"__esModule",{value:!0}),e.UNDEFINED_INPUT_ERROR=e.INVALID_BUFFER=e.isEnd=e.END=void 0,e.emitter=r,e.channel=u,e.eventChannel=o;var a=t(1),i=t(4),c="@@redux-saga/CHANNEL_END",f=e.END={type:c},l=e.isEnd=function(n){return n&&n.type===c},s=e.INVALID_BUFFER="invalid buffer passed to channel factory function",d=e.UNDEFINED_INPUT_ERROR="Saga was provided with an undefined action"},function(n,e,t){"use strict";function r(n,e,t){return e in n?Object.defineProperty(n,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):n[e]=t,n}function u(n,e){if(arguments.length>=2)(0,k.check)(n,k.is.notUndef,"take(channel, pattern): channel is undefined"),(0,k.check)(n,k.is.take,"take(channel, pattern): argument "+String(n)+" is not a valid channel (channel argument must have a take method)"),(0,k.check)(e,k.is.notUndef,"take(channel, pattern): pattern is undefined"),(0,k.check)(e,k.is.pattern,"take(channel, pattern): argument "+String(e)+" is not a valid pattern (pattern must be String | Function: a => boolean | Array<String>)");else if(1===arguments.length)if((0,k.check)(n,k.is.notUndef,"take(patternOrChannel): undefined argument"),k.is.take(n))e="*";else{if(!k.is.pattern(n))throw new Error("take(patternOrChannel): argument "+String(n)+" is not valid channel or a valid pattern");e=n,n=null}else e="*";return U(_,{channel:n,pattern:e})}function o(){var n=u.apply(void 0,arguments);return n[_].maybe=!0,n}function a(n,e){return arguments.length>1?((0,k.check)(n,k.is.notUndef,"put(channel, action): argument channel is undefined"),(0,k.check)(n,k.is.put,"put(channel, action): argument "+n+" is not a valid channel (channel argument must have a put method)"),(0,k.check)(e,k.is.notUndef,"put(channel, action): argument action is undefined")):((0,k.check)(n,k.is.notUndef,"put(action): argument action is undefined"),e=n,n=null),U(j,{channel:n,action:e})}function i(n){return U(O,n)}function c(n,e,t){(0,k.check)(e,k.is.notUndef,n+": argument fn is undefined");var r=null;if(k.is.array(e)){var u=e,o=m(u,2);r=o[0],e=o[1]}else if(e.fn){var a=e;r=a.context,e=a.fn}return(0,k.check)(e,k.is.func,n+": argument "+e+" is not a function"),{context:r,fn:e,args:t}}function f(n){for(var e=arguments.length,t=Array(e>1?e-1:0),r=1;e>r;r++)t[r-1]=arguments[r];return U(A,c("call",n,t))}function l(n,e){var t=arguments.length<=2||void 0===arguments[2]?[]:arguments[2];return U(A,c("apply",{context:n,fn:e},t))}function s(n){for(var e=arguments.length,t=Array(e>1?e-1:0),r=1;e>r;r++)t[r-1]=arguments[r];return U(C,c("cps",n,t))}function d(n){for(var e=arguments.length,t=Array(e>1?e-1:0),r=1;e>r;r++)t[r-1]=arguments[r];return U(w,c("fork",n,t))}function p(n){for(var e=arguments.length,t=Array(e>1?e-1:0),r=1;e>r;r++)t[r-1]=arguments[r];var u=d.apply(void 0,[n].concat(t));return u[w].detached=!0,u}function v(n){if((0,k.check)(n,k.is.notUndef,"join(task): argument task is undefined"),!x(n))throw new Error("join(task): argument "+n+" is not a valid Task object \n(HINT: if you are getting this errors in tests, consider using createMockTask from redux-saga/utils)");return U(P,n)}function h(n){if((0,k.check)(n,k.is.notUndef,"cancel(task): argument task is undefined"),!x(n))throw new Error("cancel(task): argument "+n+" is not a valid Task object \n(HINT: if you are getting this errors in tests, consider using createMockTask from redux-saga/utils)");return U(S,n)}function g(n){for(var e=arguments.length,t=Array(e>1?e-1:0),r=1;e>r;r++)t[r-1]=arguments[r];return 0===arguments.length?n=k.ident:((0,k.check)(g,k.is.notUndef,"select(selector,[...]): argument selector is undefined"),(0,k.check)(n,k.is.func,"select(selector,[...]): argument "+n+" is not a function")),U(T,{selector:n,args:t})}function y(n,e){return(0,k.check)(n,k.is.notUndef,"actionChannel(pattern,...): argument pattern is undefined"),arguments.length>1&&((0,k.check)(e,k.is.notUndef,"actionChannel(pattern, buffer): argument buffer is undefined"),(0,k.check)(e,k.is.notUndef,"actionChannel(pattern, buffer): argument "+e+" is not a valid buffer")),U(N,{pattern:n,buffer:e})}function b(){return U(R,{})}Object.defineProperty(e,"__esModule",{value:!0}),e.asEffect=void 0;var m=function(){function n(n,e){var t=[],r=!0,u=!1,o=void 0;try{for(var a,i=n[Symbol.iterator]();!(r=(a=i.next()).done)&&(t.push(a.value),!e||t.length!==e);r=!0);}catch(c){u=!0,o=c}finally{try{!r&&i.return&&i.return()}finally{if(u)throw o}}return t}return function(e,t){if(Array.isArray(e))return e;if(Symbol.iterator in Object(e))return n(e,t);throw new TypeError("Invalid attempt to destructure non-iterable instance")}}();e.take=u,e.takem=o,e.put=a,e.race=i,e.call=f,e.apply=l,e.cps=s,e.fork=d,e.spawn=p,e.join=v,e.cancel=h,e.select=g,e.actionChannel=y,e.cancelled=b;var k=t(1),E=(0,k.sym)("IO"),_="TAKE",j="PUT",O="RACE",A="CALL",C="CPS",w="FORK",P="JOIN",S="CANCEL",T="SELECT",N="ACTION_CHANNEL",R="CANCELLED",U=function(n,e){var t;return t={},r(t,E,!0),r(t,n,e),t};a.sync=function(){var n=a.apply(void 0,arguments);return n[j].sync=!0,n};var x=function(n){return n[k.TASK]};e.asEffect={take:function(n){return n&&n[E]&&n[_]},put:function(n){return n&&n[E]&&n[j]},race:function(n){return n&&n[E]&&n[O]},call:function(n){return n&&n[E]&&n[A]},cps:function(n){return n&&n[E]&&n[C]},fork:function(n){return n&&n[E]&&n[w]},join:function(n){return n&&n[E]&&n[P]},cancel:function(n){return n&&n[E]&&n[S]},select:function(n){return n&&n[E]&&n[T]},actionChannel:function(n){return n&&n[E]&&n[N]},cancelled:function(n){return n&&n[E]&&n[R]}}},function(n,e,t){"use strict";function r(){var n=arguments.length<=0||void 0===arguments[0]?1/0:arguments[0],e=arguments[1],t=[];return{isEmpty:function(){return!t.length},put:function(r){if(t.length<n)t.push(r);else switch(e){case a:throw new Error(o);case c:t.shift(),t.push(r)}},take:function(){return t.shift()}}}Object.defineProperty(e,"__esModule",{value:!0}),e.buffers=e.BUFFER_OVERFLOW=void 0;var u=t(1),o=e.BUFFER_OVERFLOW="Channel's Buffer overflow!",a=1,i=2,c=3,f={isEmpty:u.kTrue,put:u.noop,take:u.noop};e.buffers={none:function(){return f},fixed:function(n){return r(n,a)},dropping:function(n){return r(n,i)},sliding:function(n){return r(n,c)}}},function(n,e,t){"use strict";function r(n){return n&&n.__esModule?n:{"default":n}}function u(n,e){for(var t in e){var r=e[t];r.configurable=r.enumerable=!0,"value"in r&&(r.writable=!0),Object.defineProperty(n,t,r)}return n}function o(n){if(Array.isArray(n)){for(var e=0,t=Array(n.length);e<n.length;e++)t[e]=n[e];return t}return Array.from(n)}function a(n,e,t){return e in n?Object.defineProperty(n,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):n[e]=t,n}function i(n){return("*"===n?E.wildcard:l.is.array(n)?E.array:l.is.func(n)?E.predicate:E.default)(n)}function c(n,e,t){function r(n){o.push(n),n.cont=function(r,c){i||((0,l.remove)(o,n),n.cont=l.noop,c?(u(),t(r,!0)):(n===e&&(a=r),o.length||(i=!0,t(a))))}}function u(){i||(i=!0,o.forEach(function(n){n.cont=l.noop,n.cancel()}),o=[])}var o=[],a=void 0,i=!1;return r(e),{addTask:r,cancelAll:u,getTasks:function(){return o},taskNames:function(){return o.map(function(n){return n.name})}}}function f(n){function e(){W.isRunning&&!W.isCancelled&&(W.isCancelled=!0,r(k))}function t(){n._isRunning&&!n._isCancelled&&(n._isCancelled=!0,J.cancelAll(),s(k))}function r(e,t){if(!W.isRunning)throw new Error("Trying to resume an already finished generator");try{var u=void 0;t?u=n.throw(e):e===k?(W.isCancelled=!0,r.cancel(),u=l.is.func(n.return)?n.return(k):{done:!0,value:k}):u=e===m?l.is.func(n.return)?n.return():{done:!0}:n.next(e),u.done?(W.isMainRunning=!1,W.cont&&W.cont(u.value)):E(u.value,H,"",r)}catch(o){W.isCancelled&&(0,l.log)("error","uncaught at "+K,o.message),W.isMainRunning=!1,W.cont(o,!0)}}function s(e,t){n._isRunning=!1,V.close(),t?(e instanceof Error&&(e.sagaStack="at "+K+" \n "+(e.sagaStack||e.stack)),G.cont||(0,l.log)("error","uncaught",e.sagaStack||e.stack),n._error=e,n._isAborted=!0,n._deferredEnd&&n._deferredEnd.reject(e)):(e===k&&g&&(0,l.log)("info",K+" has been cancelled",""),n._result=e,n._deferredEnd&&n._deferredEnd.resolve(e)),G.cont&&G.cont(e,t),G.joiners.forEach(function(n){return n.cb(e,t)}),G.joiners=null}function E(n,e){function t(n,e){a||(a=!0,u.cancel=l.noop,q&&(e?q.effectRejected(o,n):q.effectResolved(o,n)),u(n,e))}var r=arguments.length<=2||void 0===arguments[2]?"":arguments[2],u=arguments[3],o=b();q&&q.effectTriggered({effectId:o,parentEffectId:e,label:r,effect:n});var a=void 0;t.cancel=l.noop,u.cancel=function(){if(!a){a=!0;try{t.cancel()}catch(n){(0,l.log)("error","uncaught at "+K,n.message)}t.cancel=l.noop,q&&q.effectCancelled(o)}};var i=void 0;return l.is.promise(n)?_(n,t):l.is.iterator(n)?j(n,o,K,t):l.is.array(n)?N(n,o,t):l.is.notUndef(i=p.asEffect.take(n))?O(i,t):l.is.notUndef(i=p.asEffect.put(n))?A(i,t):l.is.notUndef(i=p.asEffect.race(n))?R(i,o,t):l.is.notUndef(i=p.asEffect.call(n))?C(i,o,t):l.is.notUndef(i=p.asEffect.cps(n))?w(i,t):l.is.notUndef(i=p.asEffect.fork(n))?P(i,o,t):l.is.notUndef(i=p.asEffect.join(n))?S(i,t):l.is.notUndef(i=p.asEffect.cancel(n))?T(i,t):l.is.notUndef(i=p.asEffect.select(n))?U(i,t):l.is.notUndef(i=p.asEffect.actionChannel(n))?x(i,t):l.is.notUndef(i=p.asEffect.cancelled(n))?M(i,t):t(n)}function _(n,e){var t=n[l.CANCEL];"function"==typeof t&&(e.cancel=t),n.then(e,function(n){return e(n,!0)})}function j(n,e,t,r){f(n,I,D,F,q,e,t,r)}function O(n,e){var t=n.channel,r=n.pattern,u=n.maybe;t=t||V;var o=function(n){return n instanceof Error?e(n,!0):e((0,v.isEnd)(n)&&!u?m:n)};try{t.take(o,i(r))}catch(a){return e(a,!0)}e.cancel=o.cancel}function A(n,e){var t=n.channel,r=n.action,u=n.sync;(0,d.default)(function(){var n=void 0;try{n=(t?t.put:D)(r)}catch(o){return e(o,!0)}return u&&l.is.promise(n)?void _(n,e):e(n)})}function C(n,e,t){var r=n.context,u=n.fn,o=n.args,a=void 0;try{a=u.apply(r,o)}catch(i){return t(i,!0)}return l.is.promise(a)?_(a,t):l.is.iterator(a)?j(a,e,u.name,t):t(a)}function w(n,e){var t=n.context,r=n.fn,u=n.args;try{r.apply(t,u.concat(function(n,t){return l.is.undef(n)?e(t):e(n,!0)}))}catch(o){return e(o,!0)}}function P(n,e,t){var r=n.context,u=n.fn,o=n.args,a=n.detached,i=void 0,c=void 0,s=void 0;try{i=u.apply(r,o)}catch(p){if(!a)return t(p);c=p}s=l.is.iterator(i)?i:c?(0,l.makeIterator)(function(){throw c}):(0,l.makeIterator)(function(){var n=void 0,e={done:!1,value:i},t=function(n){return{done:!0,value:n}};return function(r){return n?t(r):(n=!0,e)}}()),d.default.suspend();var v=f(s,I,D,F,q,e,u.name,a?null:l.noop);if(!a)if(s._isRunning)J.addTask(v);else if(s._error)return t(s._error,!0);t(v),d.default.flush()}function S(n,e){n.isRunning()?!function(){var t={task:G,cb:e};e.cancel=function(){return(0,l.remove)(n.joiners,t)},n.joiners.push(t)}():n.isAborted()?e(n.error(),!0):e(n.result())}function T(n,e){n.isRunning()&&n.cancel(),e()}function N(n,e,t){function r(){u===a.length&&(o=!0,t(a))}if(!n.length)return t([]);var u=0,o=void 0,a=Array(n.length),i=n.map(function(n,e){var i=function(n,i){o||(i||(0,v.isEnd)(n)||n===m||n===k?(t.cancel(),t(n,i)):(a[e]=n,u++,r()))};return i.cancel=l.noop,i});t.cancel=function(){o||(o=!0,i.forEach(function(n){return n.cancel()}))},n.forEach(function(n,t){return E(n,e,t,i[t])})}function R(n,e,t){var r=void 0,u=Object.keys(n),o={};u.forEach(function(n){var e=function(e,u){r||(u?(t.cancel(),t(e,!0)):(0,v.isEnd)(e)||e===m||e===k||(t.cancel(),r=!0,t(a({},n,e))))};e.cancel=l.noop,o[n]=e}),t.cancel=function(){r||(r=!0,u.forEach(function(n){return o[n].cancel()}))},u.forEach(function(t){return E(n[t],e,t,o[t])})}function U(n,e){var t=n.selector,r=n.args;try{var u=t.apply(void 0,[F()].concat(o(r)));e(u)}catch(a){e(a,!0)}}function x(n,e){var t=n.pattern,r=n.buffer,u=i(t);u.pattern=t,e((0,v.eventChannel)(I,r||h.buffers.fixed(),u))}function M(n,e){e(!!W.isCancelled)}function L(n,e,r,o){var i,c,f;return r._deferredEnd=null,c={},a(c,l.TASK,!0),a(c,"id",n),a(c,"name",e),i="done",f={},f[i]=f[i]||{},f[i].get=function(){if(r._deferredEnd)return r._deferredEnd.promise;var n=(0,l.deferred)();return r._deferredEnd=n,r._isRunning||(r._error?n.reject(r._error):n.resolve(r._result)),n.promise},a(c,"cont",o),a(c,"joiners",[]),a(c,"cancel",t),a(c,"isRunning",function(){return r._isRunning}),a(c,"isCancelled",function(){return r._isCancelled}),a(c,"isAborted",function(){return r._isAborted}),a(c,"result",function(){return r._result}),a(c,"error",function(){return r._error}),u(c,f),c}var I=arguments.length<=1||void 0===arguments[1]?function(){return l.noop}:arguments[1],D=arguments.length<=2||void 0===arguments[2]?l.noop:arguments[2],F=arguments.length<=3||void 0===arguments[3]?l.noop:arguments[3],q=arguments[4],H=arguments.length<=5||void 0===arguments[5]?0:arguments[5],K=arguments.length<=6||void 0===arguments[6]?"anonymous":arguments[6],B=arguments[7];(0,l.check)(n,l.is.iterator,y);var V=(0,v.eventChannel)(I);r.cancel=l.noop;var G=L(H,K,n,B),W={name:K,cancel:e,isRunning:!0},J=c(K,W,s);return B&&(B.cancel=t),n._isRunning=!0,r(),G}Object.defineProperty(e,"__esModule",{value:!0}),e.TASK_CANCEL=e.CHANNEL_END=e.NOT_ITERATOR_ERROR=void 0,e.default=f;var l=t(1),s=t(7),d=r(s),p=t(3),v=t(2),h=t(4),g=!1,y=e.NOT_ITERATOR_ERROR="proc first argument (Saga function result) must be an iterator",b=(0,l.autoInc)(),m=e.CHANNEL_END={toString:function(){return"@@redux-saga/CHANNEL_END"}},k=e.TASK_CANCEL={toString:function(){return"@@redux-saga/TASK_CANCEL"}},E={wildcard:function(){return l.kTrue},"default":function(n){return function(e){return e.type===n}},array:function(n){return function(e){return n.some(function(n){return n===e.type})}},predicate:function(n){return function(e){return n(e)}}}},function(n,e,t){"use strict";Object.defineProperty(e,"__esModule",{value:!0});var r=t(3);Object.defineProperty(e,"take",{enumerable:!0,get:function(){return r.take}}),Object.defineProperty(e,"takem",{enumerable:!0,get:function(){return r.takem}}),Object.defineProperty(e,"put",{enumerable:!0,get:function(){return r.put}}),Object.defineProperty(e,"race",{enumerable:!0,get:function(){return r.race}}),Object.defineProperty(e,"call",{enumerable:!0,get:function(){return r.call}}),Object.defineProperty(e,"apply",{enumerable:!0,get:function(){return r.apply}}),Object.defineProperty(e,"cps",{enumerable:!0,get:function(){return r.cps}}),Object.defineProperty(e,"fork",{enumerable:!0,get:function(){return r.fork}}),Object.defineProperty(e,"spawn",{enumerable:!0,get:function(){return r.spawn}}),Object.defineProperty(e,"join",{enumerable:!0,get:function(){return r.join}}),Object.defineProperty(e,"cancel",{enumerable:!0,get:function(){return r.cancel}}),Object.defineProperty(e,"select",{enumerable:!0,get:function(){return r.select}}),Object.defineProperty(e,"actionChannel",{enumerable:!0,get:function(){return r.actionChannel}}),Object.defineProperty(e,"cancelled",{enumerable:!0,get:function(){return r.cancelled}})},function(n,e){"use strict";function t(n){u?r.push(n):(u=!0,r.push(n),t.flush())}Object.defineProperty(e,"__esModule",{value:!0}),e.default=t;var r=[],u=!1;t.suspend=function(){return u=!0},t.flush=function(){for(var n=void 0;n=r.shift();)n();u=!1}},function(n,e,t){"use strict";function r(n){return n&&n.__esModule?n:{"default":n}}function u(){function n(n){function r(n){for(var t=arguments.length,r=Array(t>1?t-1:0),c=1;t>c;c++)r[c-1]=arguments[c];return(0,i.default)(n.apply(void 0,r),a.subscribe,o,u,e.sagaMonitor,0,n.name)}var u=n.getState,o=n.dispatch;t=r;var a=(0,c.emitter)();return function(n){return function(e){var t=n(e);return a.emit(e),t}}}var e=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],t=void 0;if(o.is.func(e))throw new Error("Saga middleware no longer accept Generator functions. Use sagaMiddleware.run instead");return n.run=function(n){for(var e=arguments.length,r=Array(e>1?e-1:0),u=1;e>u;u++)r[u-1]=arguments[u];return(0,o.check)(t,o.is.notUndef,"Before running a Saga, you must mount the Saga middleware on the Store using applyMiddleware"),(0,o.check)(n,o.is.func,"sagaMiddleware.run(saga, ...args): saga argument must be a Generator function!"),t.apply(void 0,[n].concat(r))},n}Object.defineProperty(e,"__esModule",{value:!0}),e.default=u;var o=t(1),a=t(5),i=r(a),c=t(2)},function(n,e,t){"use strict";function r(n){return n&&n.__esModule?n:{"default":n}}function u(n,e,t){var r=e.subscribe,u=e.dispatch,a=e.getState;return(0,o.check)(n,o.is.iterator,"runSaga must be called on an iterator"),(0,i.default)(n,r,u,a,t)}Object.defineProperty(e,"__esModule",{value:!0}),e.runSaga=u;var o=t(1),a=t(5),i=r(a)},function(n,e,t){"use strict";function r(n,e){function t(e,t){if(o===d)return s;if(t)throw o=d,t;u&&u(e);var r=n[o](),a=i(r,3),c=a[0],f=a[1],l=a[2];return o=c,u=l,o===d?s:f}var r=arguments.length<=2||void 0===arguments[2]?"iterator":arguments[2],u=void 0,o=e;return(0,f.makeIterator)(t,function(n){return t(null,n)},r)}function u(n){return Array.isArray(n)?String(n.map(function(n){return String(n)})):String(n)}function o(n,e){for(var t=arguments.length,o=Array(t>2?t-2:0),a=2;t>a;a++)o[a-2]=arguments[a];var i={done:!1,value:(0,l.take)(n)},f=function(n){return{done:!1,value:l.fork.apply(void 0,[e].concat(o,[n]))}},s=void 0,p=function(n){return s=n};return r({q1:function(){return["q2",i,p]},q2:function(){return s===c.END?[d]:["q1",f(s)]}},"q1","takeEvery("+u(n)+", "+e.name+")")}function a(n,e){for(var t=arguments.length,o=Array(t>2?t-2:0),a=2;t>a;a++)o[a-2]=arguments[a];var i={done:!1,value:(0,l.take)(n)},f=function(n){return{done:!1,value:l.fork.apply(void 0,[e].concat(o,[n]))}},s=function(n){return{done:!1,value:(0,l.cancel)(n)}},p=void 0,v=void 0,h=function(n){return p=n},g=function(n){return v=n};return r({q1:function(){return["q2",i,g]},q2:function(){return v===c.END?[d]:p?["q3",s(p)]:["q1",f(v),h]},q3:function(){return["q1",f(v),h]}},"q1","takeLatest("+u(n)+", "+e.name+")")}Object.defineProperty(e,"__esModule",{value:!0});var i=function(){function n(n,e){var t=[],r=!0,u=!1,o=void 0;try{for(var a,i=n[Symbol.iterator]();!(r=(a=i.next()).done)&&(t.push(a.value),!e||t.length!==e);r=!0);}catch(c){u=!0,o=c}finally{try{!r&&i.return&&i.return()}finally{if(u)throw o}}return t}return function(e,t){if(Array.isArray(e))return e;if(Symbol.iterator in Object(e))return n(e,t);throw new TypeError("Invalid attempt to destructure non-iterable instance")}}();e.takeEvery=o,e.takeLatest=a;var c=t(2),f=t(1),l=t(3),s={done:!0,value:void 0},d={}},function(n,e,t){"use strict";Object.defineProperty(e,"__esModule",{value:!0});var r=t(1);Object.defineProperty(e,"TASK",{enumerable:!0,get:function(){return r.TASK}}),Object.defineProperty(e,"noop",{enumerable:!0,get:function(){return r.noop}}),Object.defineProperty(e,"is",{enumerable:!0,get:function(){return r.is}}),Object.defineProperty(e,"deferred",{enumerable:!0,get:function(){return r.deferred}}),Object.defineProperty(e,"arrayOfDeffered",{enumerable:!0,get:function(){return r.arrayOfDeffered}}),Object.defineProperty(e,"createMockTask",{enumerable:!0,get:function(){return r.createMockTask}});var u=t(3);Object.defineProperty(e,"asEffect",{enumerable:!0,get:function(){return u.asEffect}})}])});
+!function(n,e){"object"==typeof exports&&"object"==typeof module?module.exports=e():"function"==typeof define&&define.amd?define([],e):"object"==typeof exports?exports.ReduxSaga=e():n.ReduxSaga=e()}(this,function(){return function(n){function e(r){if(t[r])return t[r].exports;var u=t[r]={exports:{},id:r,loaded:!1};return n[r].call(u.exports,u,u.exports,e),u.loaded=!0,u.exports}var t={};return e.m=n,e.c=t,e.p="",e(0)}([function(n,e,t){"use strict";function r(n){if(n&&n.__esModule)return n;var e={};if(null!=n)for(var t in n)Object.prototype.hasOwnProperty.call(n,t)&&(e[t]=n[t]);return e.default=n,e}function u(n){return n&&n.__esModule?n:{"default":n}}Object.defineProperty(e,"__esModule",{value:!0}),e.utils=e.effects=e.CANCEL=e.delay=e.takeLatest=e.takeEvery=e.buffers=e.channel=e.eventChannel=e.END=e.runSaga=void 0;var o=t(9);Object.defineProperty(e,"runSaga",{enumerable:!0,get:function(){return o.runSaga}});var a=t(2);Object.defineProperty(e,"END",{enumerable:!0,get:function(){return a.END}}),Object.defineProperty(e,"eventChannel",{enumerable:!0,get:function(){return a.eventChannel}}),Object.defineProperty(e,"channel",{enumerable:!0,get:function(){return a.channel}});var i=t(4);Object.defineProperty(e,"buffers",{enumerable:!0,get:function(){return i.buffers}});var c=t(10);Object.defineProperty(e,"takeEvery",{enumerable:!0,get:function(){return c.takeEvery}}),Object.defineProperty(e,"takeLatest",{enumerable:!0,get:function(){return c.takeLatest}});var f=t(1);Object.defineProperty(e,"delay",{enumerable:!0,get:function(){return f.delay}}),Object.defineProperty(e,"CANCEL",{enumerable:!0,get:function(){return f.CANCEL}});var l=t(8),s=u(l),d=t(6),p=r(d),v=t(11),g=r(v);e.default=s.default,e.effects=p,e.utils=g},function(n,e){"use strict";function t(n,e,t){return e in n?Object.defineProperty(n,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):n[e]=t,n}function r(n,e,t){if(!e(n))throw s("error","uncaught at check",t),new Error(t)}function u(n,e){var t=n.indexOf(e);t>=0&&n.splice(t,1)}function o(){var n=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],e=d({},n),t=new Promise(function(n,t){e.resolve=n,e.reject=t});return e.promise=t,e}function a(n){for(var e=[],t=0;n>t;t++)e.push(o());return e}function i(n){var e=arguments.length<=1||void 0===arguments[1]?!0:arguments[1],t=void 0,r=new Promise(function(r){t=setTimeout(function(){return r(e)},n)});return r[h]=function(){return clearTimeout(t)},r}function c(){var n,e=!0,r=void 0,u=void 0;return n={},t(n,g,!0),t(n,"isRunning",function(){return e}),t(n,"result",function(){return r}),t(n,"error",function(){return u}),t(n,"setRunning",function(n){return e=n}),t(n,"setResult",function(n){return r=n}),t(n,"setError",function(n){return u=n}),n}function f(){var n=arguments.length<=0||void 0===arguments[0]?0:arguments[0];return function(){return++n}}function l(n){var e=arguments.length<=1||void 0===arguments[1]?m:arguments[1],t=arguments.length<=2||void 0===arguments[2]?"":arguments[2],r={name:t,next:n,"throw":e};return"undefined"!=typeof Symbol&&(r[Symbol.iterator]=function(){return r}),r}function s(n,e,t){"undefined"==typeof window?console.log("redux-saga "+n+": "+e+"\n"+(t&&t.stack||t)):console[n].call(console,e,t)}Object.defineProperty(e,"__esModule",{value:!0});var d=Object.assign||function(n){for(var e=1;e<arguments.length;e++){var t=arguments[e];for(var r in t)Object.prototype.hasOwnProperty.call(t,r)&&(n[r]=t[r])}return n},p="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(n){return typeof n}:function(n){return n&&"function"==typeof Symbol&&n.constructor===Symbol?"symbol":typeof n};e.check=r,e.remove=u,e.deferred=o,e.arrayOfDeffered=a,e.delay=i,e.createMockTask=c,e.autoInc=f,e.makeIterator=l,e.log=s;var v=e.sym=function(n){return"@@redux-saga/"+n},g=e.TASK=v("TASK"),h=(e.MATCH=v("MATCH"),e.CANCEL=v("cancelPromise")),y=e.konst=function(n){return function(){return n}},b=(e.kTrue=y(!0),e.kFalse=y(!1),e.noop=function(){},e.ident=function(n){return n},e.is={undef:function(n){return null===n||void 0===n},notUndef:function(n){return null!==n&&void 0!==n},func:function(n){return"function"==typeof n},number:function(n){return"number"==typeof n},array:Array.isArray,promise:function(n){return n&&b.func(n.then)},iterator:function(n){return n&&b.func(n.next)&&b.func(n.throw)},task:function(n){return n&&n[g]},take:function(n){return n&&b.func(n.take)},put:function(n){return n&&b.func(n.put)},observable:function(n){return n&&b.func(n.subscribe)},buffer:function(n){return n&&b.func(n.isEmpty)&&b.func(n.take)&&b.func(n.put)},pattern:function(n){return n&&("string"==typeof n||"symbol"===("undefined"==typeof n?"undefined":p(n))||b.func(n)||b.array(n))}}),m=function(n){throw n};e.internalErr=function(n){return new Error("\n  redux-saga: Error checking hooks detected an inconsisten state. This is likely a bug\n  in redux-saga code and not yours. Thanks for reporting this in the project's github repo.\n  Error: "+n+"\n")}},function(n,e,t){"use strict";function r(){function n(n){return t.push(n),function(){return(0,a.remove)(t,n)}}function e(n){for(var e=t.slice(),r=0,u=e.length;u>r;r++)e[r](n)}var t=[];return{subscribe:n,emit:e}}function u(n){function e(){if(o&&c.length)throw(0,a.internalErr)("Cannot have a closed channel with pending takers");if(c.length&&!n.isEmpty())throw(0,a.internalErr)("Cannot have pending takers with non empty buffer")}function t(t){if(e(),(0,a.check)(t,a.is.notUndef,d),!o)if(c.length)for(var r=0;r<c.length;r++){var u=c[r];if(!u[a.MATCH]||u[a.MATCH](t))return c.splice(r,1),u(t)}else n.put(t)}function r(t,r){e(),(0,a.check)(t,a.is.func,"channel.take's callback must be a function"),arguments.length>1&&((0,a.check)(r,a.is.func,"channel.take's matcher argument must be a function"),t[a.MATCH]=r),o&&n.isEmpty()?t(f):n.isEmpty()?(c.push(t),t.cancel=function(){return(0,a.remove)(c,t)}):t(n.take())}function u(){if(e(),!o&&(o=!0,c.length)){var n=c;c=[];for(var t=0,r=n.length;r>t;t++)n[t](f);c=[]}}var o=!1,c=[];return arguments.length>0?(0,a.check)(n,a.is.buffer,s):n=i.buffers.fixed(),{take:r,put:t,close:u,get __takers__(){return c},get __closed__(){return o}}}function o(n){var e=arguments.length<=1||void 0===arguments[1]?i.buffers.none():arguments[1],t=arguments[2];arguments.length>2&&(0,a.check)(t,a.is.func,"Invalid match function passed to eventChannel");var r=u(e),o=n(function(n){l(n)?r.close():t&&!t(n)||r.put(n)});return{take:r.take,close:function(){r.__closed__||(r.close(),o())}}}Object.defineProperty(e,"__esModule",{value:!0}),e.UNDEFINED_INPUT_ERROR=e.INVALID_BUFFER=e.isEnd=e.END=void 0,e.emitter=r,e.channel=u,e.eventChannel=o;var a=t(1),i=t(4),c="@@redux-saga/CHANNEL_END",f=e.END={type:c},l=e.isEnd=function(n){return n&&n.type===c},s=e.INVALID_BUFFER="invalid buffer passed to channel factory function",d=e.UNDEFINED_INPUT_ERROR="Saga was provided with an undefined action"},function(n,e,t){"use strict";function r(n,e,t){return e in n?Object.defineProperty(n,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):n[e]=t,n}function u(n,e){if(arguments.length>=2)(0,k.check)(n,k.is.notUndef,"take(channel, pattern): channel is undefined"),(0,k.check)(n,k.is.take,"take(channel, pattern): argument "+String(n)+" is not a valid channel (channel argument must have a take method)"),(0,k.check)(e,k.is.notUndef,"take(channel, pattern): pattern is undefined"),(0,k.check)(e,k.is.pattern,"take(channel, pattern): argument "+String(e)+" is not a valid pattern (pattern must be String | Function: a => boolean | Array<String>)");else if(1===arguments.length)if((0,k.check)(n,k.is.notUndef,"take(patternOrChannel): undefined argument"),k.is.take(n))e="*";else{if(!k.is.pattern(n))throw new Error("take(patternOrChannel): argument "+String(n)+" is not valid channel or a valid pattern");e=n,n=null}else e="*";return U(_,{channel:n,pattern:e})}function o(){var n=u.apply(void 0,arguments);return n[_].maybe=!0,n}function a(n,e){return arguments.length>1?((0,k.check)(n,k.is.notUndef,"put(channel, action): argument channel is undefined"),(0,k.check)(n,k.is.put,"put(channel, action): argument "+n+" is not a valid channel (channel argument must have a put method)"),(0,k.check)(e,k.is.notUndef,"put(channel, action): argument action is undefined")):((0,k.check)(n,k.is.notUndef,"put(action): argument action is undefined"),e=n,n=null),U(j,{channel:n,action:e})}function i(n){return U(O,n)}function c(n,e,t){(0,k.check)(e,k.is.notUndef,n+": argument fn is undefined");var r=null;if(k.is.array(e)){var u=e,o=m(u,2);r=o[0],e=o[1]}else if(e.fn){var a=e;r=a.context,e=a.fn}return(0,k.check)(e,k.is.func,n+": argument "+e+" is not a function"),{context:r,fn:e,args:t}}function f(n){for(var e=arguments.length,t=Array(e>1?e-1:0),r=1;e>r;r++)t[r-1]=arguments[r];return U(A,c("call",n,t))}function l(n,e){var t=arguments.length<=2||void 0===arguments[2]?[]:arguments[2];return U(A,c("apply",{context:n,fn:e},t))}function s(n){for(var e=arguments.length,t=Array(e>1?e-1:0),r=1;e>r;r++)t[r-1]=arguments[r];return U(C,c("cps",n,t))}function d(n){for(var e=arguments.length,t=Array(e>1?e-1:0),r=1;e>r;r++)t[r-1]=arguments[r];return U(w,c("fork",n,t))}function p(n){for(var e=arguments.length,t=Array(e>1?e-1:0),r=1;e>r;r++)t[r-1]=arguments[r];var u=d.apply(void 0,[n].concat(t));return u[w].detached=!0,u}function v(n){if((0,k.check)(n,k.is.notUndef,"join(task): argument task is undefined"),!x(n))throw new Error("join(task): argument "+n+" is not a valid Task object \n(HINT: if you are getting this errors in tests, consider using createMockTask from redux-saga/utils)");return U(P,n)}function g(n){if((0,k.check)(n,k.is.notUndef,"cancel(task): argument task is undefined"),!x(n))throw new Error("cancel(task): argument "+n+" is not a valid Task object \n(HINT: if you are getting this errors in tests, consider using createMockTask from redux-saga/utils)");return U(S,n)}function h(n){for(var e=arguments.length,t=Array(e>1?e-1:0),r=1;e>r;r++)t[r-1]=arguments[r];return 0===arguments.length?n=k.ident:((0,k.check)(h,k.is.notUndef,"select(selector,[...]): argument selector is undefined"),(0,k.check)(n,k.is.func,"select(selector,[...]): argument "+n+" is not a function")),U(T,{selector:n,args:t})}function y(n,e){return(0,k.check)(n,k.is.notUndef,"actionChannel(pattern,...): argument pattern is undefined"),arguments.length>1&&((0,k.check)(e,k.is.notUndef,"actionChannel(pattern, buffer): argument buffer is undefined"),(0,k.check)(e,k.is.notUndef,"actionChannel(pattern, buffer): argument "+e+" is not a valid buffer")),U(N,{pattern:n,buffer:e})}function b(){return U(R,{})}Object.defineProperty(e,"__esModule",{value:!0}),e.asEffect=void 0;var m=function(){function n(n,e){var t=[],r=!0,u=!1,o=void 0;try{for(var a,i=n[Symbol.iterator]();!(r=(a=i.next()).done)&&(t.push(a.value),!e||t.length!==e);r=!0);}catch(c){u=!0,o=c}finally{try{!r&&i.return&&i.return()}finally{if(u)throw o}}return t}return function(e,t){if(Array.isArray(e))return e;if(Symbol.iterator in Object(e))return n(e,t);throw new TypeError("Invalid attempt to destructure non-iterable instance")}}();e.take=u,e.takem=o,e.put=a,e.race=i,e.call=f,e.apply=l,e.cps=s,e.fork=d,e.spawn=p,e.join=v,e.cancel=g,e.select=h,e.actionChannel=y,e.cancelled=b;var k=t(1),E=(0,k.sym)("IO"),_="TAKE",j="PUT",O="RACE",A="CALL",C="CPS",w="FORK",P="JOIN",S="CANCEL",T="SELECT",N="ACTION_CHANNEL",R="CANCELLED",U=function(n,e){var t;return t={},r(t,E,!0),r(t,n,e),t};a.sync=function(){var n=a.apply(void 0,arguments);return n[j].sync=!0,n};var x=function(n){return n[k.TASK]};e.asEffect={take:function(n){return n&&n[E]&&n[_]},put:function(n){return n&&n[E]&&n[j]},race:function(n){return n&&n[E]&&n[O]},call:function(n){return n&&n[E]&&n[A]},cps:function(n){return n&&n[E]&&n[C]},fork:function(n){return n&&n[E]&&n[w]},join:function(n){return n&&n[E]&&n[P]},cancel:function(n){return n&&n[E]&&n[S]},select:function(n){return n&&n[E]&&n[T]},actionChannel:function(n){return n&&n[E]&&n[N]},cancelled:function(n){return n&&n[E]&&n[R]}}},function(n,e,t){"use strict";function r(){var n=arguments.length<=0||void 0===arguments[0]?1/0:arguments[0],e=arguments[1],t=[];return{isEmpty:function(){return!t.length},put:function(r){if(t.length<n)t.push(r);else switch(e){case a:throw new Error(o);case c:t.shift(),t.push(r)}},take:function(){return t.shift()}}}Object.defineProperty(e,"__esModule",{value:!0}),e.buffers=e.BUFFER_OVERFLOW=void 0;var u=t(1),o=e.BUFFER_OVERFLOW="Channel's Buffer overflow!",a=1,i=2,c=3,f={isEmpty:u.kTrue,put:u.noop,take:u.noop};e.buffers={none:function(){return f},fixed:function(n){return r(n,a)},dropping:function(n){return r(n,i)},sliding:function(n){return r(n,c)}}},function(n,e,t){"use strict";function r(n){return n&&n.__esModule?n:{"default":n}}function u(n,e){for(var t in e){var r=e[t];r.configurable=r.enumerable=!0,"value"in r&&(r.writable=!0),Object.defineProperty(n,t,r)}return n}function o(n){if(Array.isArray(n)){for(var e=0,t=Array(n.length);e<n.length;e++)t[e]=n[e];return t}return Array.from(n)}function a(n,e,t){return e in n?Object.defineProperty(n,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):n[e]=t,n}function i(n){return("*"===n?E.wildcard:l.is.array(n)?E.array:l.is.func(n)?E.predicate:E.default)(n)}function c(n,e,t){function r(n){o.push(n),n.cont=function(r,c){i||((0,l.remove)(o,n),n.cont=l.noop,c?(u(),t(r,!0)):(n===e&&(a=r),o.length||(i=!0,t(a))))}}function u(){i||(i=!0,o.forEach(function(n){n.cont=l.noop,n.cancel()}),o=[])}var o=[],a=void 0,i=!1;return r(e),{addTask:r,cancelAll:u,getTasks:function(){return o},taskNames:function(){return o.map(function(n){return n.name})}}}function f(n){function e(){Q.isRunning&&!Q.isCancelled&&(Q.isCancelled=!0,r(k))}function t(){n._isRunning&&!n._isCancelled&&(n._isCancelled=!0,X.cancelAll(),s(k))}function r(e,t){if(!Q.isRunning)throw new Error("Trying to resume an already finished generator");try{var u=void 0;t?u=n.throw(e):e===k?(Q.isCancelled=!0,r.cancel(),u=l.is.func(n.return)?n.return(k):{done:!0,value:k}):u=e===m?l.is.func(n.return)?n.return():{done:!0}:n.next(e),u.done?(Q.isMainRunning=!1,Q.cont&&Q.cont(u.value)):E(u.value,H,"",r)}catch(o){Q.isCancelled&&W("error","uncaught at "+K,o.message),Q.isMainRunning=!1,Q.cont(o,!0)}}function s(e,t){n._isRunning=!1,J.close(),t?(e instanceof Error&&(e.sagaStack="at "+K+" \n "+(e.sagaStack||e.stack)),z.cont||W("error","uncaught",e.sagaStack||e.stack),n._error=e,n._isAborted=!0,n._deferredEnd&&n._deferredEnd.reject(e)):(e===k&&h&&W("info",K+" has been cancelled",""),n._result=e,n._deferredEnd&&n._deferredEnd.resolve(e)),z.cont&&z.cont(e,t),z.joiners.forEach(function(n){return n.cb(e,t)}),z.joiners=null}function E(n,e){function t(n,e){a||(a=!0,u.cancel=l.noop,V&&(e?V.effectRejected(o,n):V.effectResolved(o,n)),u(n,e))}var r=arguments.length<=2||void 0===arguments[2]?"":arguments[2],u=arguments[3],o=b();V&&V.effectTriggered({effectId:o,parentEffectId:e,label:r,effect:n});var a=void 0;t.cancel=l.noop,u.cancel=function(){if(!a){a=!0;try{t.cancel()}catch(n){W("error","uncaught at "+K,n.message)}t.cancel=l.noop,V&&V.effectCancelled(o)}};var i=void 0;return l.is.promise(n)?_(n,t):l.is.iterator(n)?j(n,o,K,t):l.is.array(n)?N(n,o,t):l.is.notUndef(i=p.asEffect.take(n))?O(i,t):l.is.notUndef(i=p.asEffect.put(n))?A(i,t):l.is.notUndef(i=p.asEffect.race(n))?R(i,o,t):l.is.notUndef(i=p.asEffect.call(n))?C(i,o,t):l.is.notUndef(i=p.asEffect.cps(n))?w(i,t):l.is.notUndef(i=p.asEffect.fork(n))?P(i,o,t):l.is.notUndef(i=p.asEffect.join(n))?S(i,t):l.is.notUndef(i=p.asEffect.cancel(n))?T(i,t):l.is.notUndef(i=p.asEffect.select(n))?U(i,t):l.is.notUndef(i=p.asEffect.actionChannel(n))?x(i,t):l.is.notUndef(i=p.asEffect.cancelled(n))?M(i,t):t(n)}function _(n,e){var t=n[l.CANCEL];"function"==typeof t&&(e.cancel=t),n.then(e,function(n){return e(n,!0)})}function j(n,e,t,r){f(n,I,D,F,q,e,t,r)}function O(n,e){var t=n.channel,r=n.pattern,u=n.maybe;t=t||J;var o=function(n){return n instanceof Error?e(n,!0):e((0,v.isEnd)(n)&&!u?m:n)};try{t.take(o,i(r))}catch(a){return e(a,!0)}e.cancel=o.cancel}function A(n,e){var t=n.channel,r=n.action,u=n.sync;(0,d.default)(function(){var n=void 0;try{n=(t?t.put:D)(r)}catch(o){return e(o,!0)}return u&&l.is.promise(n)?void _(n,e):e(n)})}function C(n,e,t){var r=n.context,u=n.fn,o=n.args,a=void 0;try{a=u.apply(r,o)}catch(i){return t(i,!0)}return l.is.promise(a)?_(a,t):l.is.iterator(a)?j(a,e,u.name,t):t(a)}function w(n,e){var t=n.context,r=n.fn,u=n.args;try{r.apply(t,u.concat(function(n,t){return l.is.undef(n)?e(t):e(n,!0)}))}catch(o){return e(o,!0)}}function P(n,e,t){var r=n.context,u=n.fn,o=n.args,a=n.detached,i=void 0,c=void 0,s=void 0;try{i=u.apply(r,o)}catch(p){if(!a)return t(p);c=p}s=l.is.iterator(i)?i:c?(0,l.makeIterator)(function(){throw c}):(0,l.makeIterator)(function(){var n=void 0,e={done:!1,value:i},t=function(n){return{done:!0,value:n}};return function(r){return n?t(r):(n=!0,e)}}()),d.default.suspend();var v=f(s,I,D,F,q,e,u.name,a?null:l.noop);if(!a)if(s._isRunning)X.addTask(v);else if(s._error)return t(s._error,!0);t(v),d.default.flush()}function S(n,e){n.isRunning()?!function(){var t={task:z,cb:e};e.cancel=function(){return(0,l.remove)(n.joiners,t)},n.joiners.push(t)}():n.isAborted()?e(n.error(),!0):e(n.result())}function T(n,e){n.isRunning()&&n.cancel(),e()}function N(n,e,t){function r(){u===a.length&&(o=!0,t(a))}if(!n.length)return t([]);var u=0,o=void 0,a=Array(n.length),i=n.map(function(n,e){var i=function(n,i){o||(i||(0,v.isEnd)(n)||n===m||n===k?(t.cancel(),t(n,i)):(a[e]=n,u++,r()))};return i.cancel=l.noop,i});t.cancel=function(){o||(o=!0,i.forEach(function(n){return n.cancel()}))},n.forEach(function(n,t){return E(n,e,t,i[t])})}function R(n,e,t){var r=void 0,u=Object.keys(n),o={};u.forEach(function(n){var e=function(e,u){r||(u?(t.cancel(),t(e,!0)):(0,v.isEnd)(e)||e===m||e===k||(t.cancel(),r=!0,t(a({},n,e))))};e.cancel=l.noop,o[n]=e}),t.cancel=function(){r||(r=!0,u.forEach(function(n){return o[n].cancel()}))},u.forEach(function(t){return E(n[t],e,t,o[t])})}function U(n,e){var t=n.selector,r=n.args;try{var u=t.apply(void 0,[F()].concat(o(r)));e(u)}catch(a){e(a,!0)}}function x(n,e){var t=n.pattern,r=n.buffer,u=i(t);u.pattern=t,e((0,v.eventChannel)(I,r||g.buffers.fixed(),u))}function M(n,e){e(!!Q.isCancelled)}function L(n,e,r,o){var i,c,f;return r._deferredEnd=null,c={},a(c,l.TASK,!0),a(c,"id",n),a(c,"name",e),i="done",f={},f[i]=f[i]||{},f[i].get=function(){if(r._deferredEnd)return r._deferredEnd.promise;var n=(0,l.deferred)();return r._deferredEnd=n,r._isRunning||(r._error?n.reject(r._error):n.resolve(r._result)),n.promise},a(c,"cont",o),a(c,"joiners",[]),a(c,"cancel",t),a(c,"isRunning",function(){return r._isRunning}),a(c,"isCancelled",function(){return r._isCancelled}),a(c,"isAborted",function(){return r._isAborted}),a(c,"result",function(){return r._result}),a(c,"error",function(){return r._error}),u(c,f),c}var I=arguments.length<=1||void 0===arguments[1]?function(){return l.noop}:arguments[1],D=arguments.length<=2||void 0===arguments[2]?l.noop:arguments[2],F=arguments.length<=3||void 0===arguments[3]?l.noop:arguments[3],q=arguments.length<=4||void 0===arguments[4]?{}:arguments[4],H=arguments.length<=5||void 0===arguments[5]?0:arguments[5],K=arguments.length<=6||void 0===arguments[6]?"anonymous":arguments[6],B=arguments[7];(0,l.check)(n,l.is.iterator,y);var V=q.sagaMonitor,G=q.logger,W=G||l.log,J=(0,v.eventChannel)(I);r.cancel=l.noop;var z=L(H,K,n,B),Q={name:K,cancel:e,isRunning:!0},X=c(K,Q,s);return B&&(B.cancel=t),n._isRunning=!0,r(),z}Object.defineProperty(e,"__esModule",{value:!0}),e.TASK_CANCEL=e.CHANNEL_END=e.NOT_ITERATOR_ERROR=void 0,e.default=f;var l=t(1),s=t(7),d=r(s),p=t(3),v=t(2),g=t(4),h=!1,y=e.NOT_ITERATOR_ERROR="proc first argument (Saga function result) must be an iterator",b=(0,l.autoInc)(),m=e.CHANNEL_END={toString:function(){return"@@redux-saga/CHANNEL_END"}},k=e.TASK_CANCEL={toString:function(){return"@@redux-saga/TASK_CANCEL"}},E={wildcard:function(){return l.kTrue},"default":function(n){return function(e){return e.type===n}},array:function(n){return function(e){return n.some(function(n){return n===e.type})}},predicate:function(n){return function(e){return n(e)}}}},function(n,e,t){"use strict";Object.defineProperty(e,"__esModule",{value:!0});var r=t(3);Object.defineProperty(e,"take",{enumerable:!0,get:function(){return r.take}}),Object.defineProperty(e,"takem",{enumerable:!0,get:function(){return r.takem}}),Object.defineProperty(e,"put",{enumerable:!0,get:function(){return r.put}}),Object.defineProperty(e,"race",{enumerable:!0,get:function(){return r.race}}),Object.defineProperty(e,"call",{enumerable:!0,get:function(){return r.call}}),Object.defineProperty(e,"apply",{enumerable:!0,get:function(){return r.apply}}),Object.defineProperty(e,"cps",{enumerable:!0,get:function(){return r.cps}}),Object.defineProperty(e,"fork",{enumerable:!0,get:function(){return r.fork}}),Object.defineProperty(e,"spawn",{enumerable:!0,get:function(){return r.spawn}}),Object.defineProperty(e,"join",{enumerable:!0,get:function(){return r.join}}),Object.defineProperty(e,"cancel",{enumerable:!0,get:function(){return r.cancel}}),Object.defineProperty(e,"select",{enumerable:!0,get:function(){return r.select}}),Object.defineProperty(e,"actionChannel",{enumerable:!0,get:function(){return r.actionChannel}}),Object.defineProperty(e,"cancelled",{enumerable:!0,get:function(){return r.cancelled}})},function(n,e){"use strict";function t(n){u?r.push(n):(u=!0,r.push(n),t.flush())}Object.defineProperty(e,"__esModule",{value:!0}),e.default=t;var r=[],u=!1;t.suspend=function(){return u=!0},t.flush=function(){for(var n=void 0;n=r.shift();)n();u=!1}},function(n,e,t){"use strict";function r(n){return n&&n.__esModule?n:{"default":n}}function u(){function n(n){function r(n){for(var t=arguments.length,r=Array(t>1?t-1:0),c=1;t>c;c++)r[c-1]=arguments[c];return(0,i.default)(n.apply(void 0,r),a.subscribe,o,u,e,0,n.name)}var u=n.getState,o=n.dispatch;t=r;var a=(0,c.emitter)();return function(n){return function(e){var t=n(e);return a.emit(e),t}}}var e=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],t=void 0;if(o.is.func(e))throw new Error("Saga middleware no longer accept Generator functions. Use sagaMiddleware.run instead");if(e.logger&&!o.is.func(e.logger))throw new Error("`options.logger` passed to the Saga middleware is not a function!");return n.run=function(n){for(var e=arguments.length,r=Array(e>1?e-1:0),u=1;e>u;u++)r[u-1]=arguments[u];return(0,o.check)(t,o.is.notUndef,"Before running a Saga, you must mount the Saga middleware on the Store using applyMiddleware"),(0,o.check)(n,o.is.func,"sagaMiddleware.run(saga, ...args): saga argument must be a Generator function!"),t.apply(void 0,[n].concat(r))},n}Object.defineProperty(e,"__esModule",{value:!0}),e.default=u;var o=t(1),a=t(5),i=r(a),c=t(2)},function(n,e,t){"use strict";function r(n){return n&&n.__esModule?n:{"default":n}}function u(n,e){var t=e.subscribe,r=e.dispatch,u=e.getState,a=e.sagaMonitor,c=e.logger;return(0,o.check)(n,o.is.iterator,"runSaga must be called on an iterator"),(0,i.default)(n,t,r,u,{sagaMonitor:a,logger:c})}Object.defineProperty(e,"__esModule",{value:!0}),e.runSaga=u;var o=t(1),a=t(5),i=r(a)},function(n,e,t){"use strict";function r(n,e){function t(e,t){if(o===d)return s;if(t)throw o=d,t;u&&u(e);var r=n[o](),a=i(r,3),c=a[0],f=a[1],l=a[2];return o=c,u=l,o===d?s:f}var r=arguments.length<=2||void 0===arguments[2]?"iterator":arguments[2],u=void 0,o=e;return(0,f.makeIterator)(t,function(n){return t(null,n)},r)}function u(n){return Array.isArray(n)?String(n.map(function(n){return String(n)})):String(n)}function o(n,e){for(var t=arguments.length,o=Array(t>2?t-2:0),a=2;t>a;a++)o[a-2]=arguments[a];var i={done:!1,value:(0,l.take)(n)},f=function(n){return{done:!1,value:l.fork.apply(void 0,[e].concat(o,[n]))}},s=void 0,p=function(n){return s=n};return r({q1:function(){return["q2",i,p]},q2:function(){return s===c.END?[d]:["q1",f(s)]}},"q1","takeEvery("+u(n)+", "+e.name+")")}function a(n,e){for(var t=arguments.length,o=Array(t>2?t-2:0),a=2;t>a;a++)o[a-2]=arguments[a];var i={done:!1,value:(0,l.take)(n)},f=function(n){return{done:!1,value:l.fork.apply(void 0,[e].concat(o,[n]))}},s=function(n){return{done:!1,value:(0,l.cancel)(n)}},p=void 0,v=void 0,g=function(n){return p=n},h=function(n){return v=n};return r({q1:function(){return["q2",i,h]},q2:function(){return v===c.END?[d]:p?["q3",s(p)]:["q1",f(v),g]},q3:function(){return["q1",f(v),g]}},"q1","takeLatest("+u(n)+", "+e.name+")")}Object.defineProperty(e,"__esModule",{value:!0});var i=function(){function n(n,e){var t=[],r=!0,u=!1,o=void 0;try{for(var a,i=n[Symbol.iterator]();!(r=(a=i.next()).done)&&(t.push(a.value),!e||t.length!==e);r=!0);}catch(c){u=!0,o=c}finally{try{!r&&i.return&&i.return()}finally{if(u)throw o}}return t}return function(e,t){if(Array.isArray(e))return e;if(Symbol.iterator in Object(e))return n(e,t);throw new TypeError("Invalid attempt to destructure non-iterable instance")}}();e.takeEvery=o,e.takeLatest=a;var c=t(2),f=t(1),l=t(3),s={done:!0,value:void 0},d={}},function(n,e,t){"use strict";Object.defineProperty(e,"__esModule",{value:!0});var r=t(1);Object.defineProperty(e,"TASK",{enumerable:!0,get:function(){return r.TASK}}),Object.defineProperty(e,"noop",{enumerable:!0,get:function(){return r.noop}}),Object.defineProperty(e,"is",{enumerable:!0,get:function(){return r.is}}),Object.defineProperty(e,"deferred",{enumerable:!0,get:function(){return r.deferred}}),Object.defineProperty(e,"arrayOfDeffered",{enumerable:!0,get:function(){return r.arrayOfDeffered}}),Object.defineProperty(e,"createMockTask",{enumerable:!0,get:function(){return r.createMockTask}});var u=t(3);Object.defineProperty(e,"asEffect",{enumerable:!0,get:function(){return u.asEffect}})}])});

lib/internal/middleware.js

@@ -31,2 +31,6 @@ 'use strict';
 
+  if (options.logger && !_utils.is.func(options.logger)) {
+    throw new Error('`options.logger` passed to the Saga middleware is not a function!');
+  }
+
   function sagaMiddleware(_ref) {
@@ -44,3 +48,3 @@ var getState = _ref.getState;
 
-      return (0, _proc2.default)(saga.apply(undefined, args), sagaEmitter.subscribe, dispatch, getState, options.sagaMonitor, 0, saga.name);
+      return (0, _proc2.default)(saga.apply(undefined, args), sagaEmitter.subscribe, dispatch, getState, options, 0, saga.name);
     }
@@ -47,0 +51,0 @@

lib/internal/proc.js

@@ -150,3 +150,3 @@ 'use strict';
   var getState = arguments.length <= 3 || arguments[3] === undefined ? _utils.noop : arguments[3];
-  var monitor = arguments[4];
+  var options = arguments.length <= 4 || arguments[4] === undefined ? {} : arguments[4];
   var parentEffectId = arguments.length <= 5 || arguments[5] === undefined ? 0 : arguments[5];
@@ -158,2 +158,6 @@ var name = arguments.length <= 6 || arguments[6] === undefined ? 'anonymous' : arguments[6];
 
+  var sagaMonitor = options.sagaMonitor;
+  var logger = options.logger;
+
+  var log = logger || _utils.log;
   var stdChannel = (0, _channel.eventChannel)(subscribe);
@@ -271,3 +275,3 @@ /**
       if (mainTask.isCancelled) {
-        (0, _utils.log)('error', 'uncaught at ' + name, error.message);
+        log('error', 'uncaught at ' + name, error.message);
       }
@@ -284,3 +288,3 @@ mainTask.isMainRunning = false;
       if (result === TASK_CANCEL && isDev) {
-        (0, _utils.log)('info', name + ' has been cancelled', '');
+        log('info', name + ' has been cancelled', '');
       }
@@ -294,3 +298,3 @@ iterator._result = result;
       if (!task.cont) {
-        (0, _utils.log)('error', 'uncaught', result.sagaStack || result.stack);
+        log('error', 'uncaught', result.sagaStack || result.stack);
       }
@@ -313,3 +317,3 @@ iterator._error = result;
     var effectId = nextEffectId();
-    monitor && monitor.effectTriggered({ effectId: effectId, parentEffectId: parentEffectId, label: label, effect: effect });
+    sagaMonitor && sagaMonitor.effectTriggered({ effectId: effectId, parentEffectId: parentEffectId, label: label, effect: effect });
 
@@ -331,4 +335,4 @@ /**
       cb.cancel = _utils.noop; // defensive measure
-      if (monitor) {
-        isErr ? monitor.effectRejected(effectId, res) : monitor.effectResolved(effectId, res);
+      if (sagaMonitor) {
+        isErr ? sagaMonitor.effectRejected(effectId, res) : sagaMonitor.effectResolved(effectId, res);
       }
@@ -357,7 +361,7 @@
       } catch (err) {
-        (0, _utils.log)('error', 'uncaught at ' + name, err.message);
+        log('error', 'uncaught at ' + name, err.message);
       }
       currCb.cancel = _utils.noop; // defensive measure
 
-      monitor && monitor.effectCancelled(effectId);
+      sagaMonitor && sagaMonitor.effectCancelled(effectId);
     };
@@ -398,3 +402,3 @@
   function resolveIterator(iterator, effectId, name, cb) {
-    proc(iterator, subscribe, dispatch, getState, monitor, effectId, name, cb);
+    proc(iterator, subscribe, dispatch, getState, options, effectId, name, cb);
   }
@@ -532,3 +536,3 @@
     _asap2.default.suspend();
-    var task = proc(_iterator, subscribe, dispatch, getState, monitor, effectId, fn.name, detached ? null : _utils.noop);
+    var task = proc(_iterator, subscribe, dispatch, getState, options, effectId, fn.name, detached ? null : _utils.noop);
     if (!detached) {
@@ -535,0 +539,0 @@ if (_iterator._isRunning) {

lib/internal/runSaga.js

@@ -16,6 +16,8 @@ 'use strict';
 
-function runSaga(iterator, _ref, monitor) {
+function runSaga(iterator, _ref) {
   var subscribe = _ref.subscribe;
   var dispatch = _ref.dispatch;
   var getState = _ref.getState;
+  var sagaMonitor = _ref.sagaMonitor;
+  var logger = _ref.logger;
 
@@ -25,3 +27,3 @@
 
-  return (0, _proc2.default)(iterator, subscribe, dispatch, getState, monitor);
+  return (0, _proc2.default)(iterator, subscribe, dispatch, getState, { sagaMonitor: sagaMonitor, logger: logger });
 }

package.json

 {
   "name": "redux-saga",
-  "version": "0.10.5",
+  "version": "0.11.0",
   "description": "Saga middleware for Redux to handle Side Effects",
   "main": "lib/index.js",
-  "jsnext:main": "src/index.js",
+  "jsnext:main": "es/index.js",
   "scripts": {
     "lint": "eslint src",
-    "test": "babel-node test/index.js | tap-spec",
+    "test": "cross-env BABEL_ENV=cjs babel-node test/index.js | tap-spec",
     "check": "npm run lint && npm run test",
-    "compile": "rimraf lib && babel -d lib/ src/",
-    "build:umd:dev": "webpack src/index.js dist/redux-saga.js --config webpack.config.dev.js",
-    "build:umd:prod": "webpack src/index.js dist/redux-saga.min.js --config webpack.config.prod.js",
-    "build:umd": "rimraf dist && npm run build:umd:dev && npm run build:umd:prod",
-    "prepublish": "npm run check && npm run compile && npm run build:umd",
-    "counter": "node examples/counter/server.js",
-    "cancellable-counter": "node examples/cancellable-counter/server.js",
-    "test-counter": "babel-node examples/counter/test/sagas.js | tap-spec",
-    "shop": "node examples/shopping-cart/server.js",
-    "test-shop": "babel-node examples/shopping-cart/test/sagas.js | tap-spec",
-    "async": "node examples/async/server.js",
-    "test-async": "babel-node examples/async/test/sagas.js | tap-spec",
-    "real-world": "npm --prefix examples/real-world install examples/real-world && node --require babel-register examples/real-world/server.js",
+    "compile": "rimraf lib && cross-env BABEL_ENV=cjs babel -d lib/ src/",
+    "build:umd:dev": "cross-env BABEL_ENV=cjs webpack src/index.js dist/redux-saga.js --config webpack.config.dev.js",
+    "build:umd:prod": "cross-env BABEL_ENV=cjs webpack src/index.js dist/redux-saga.min.js --config webpack.config.prod.js",
+    "build:es": "cross-env BABEL_ENV=es babel src --out-dir es",
+    "build": "rimraf dist es && npm run build:umd:dev && npm run build:umd:prod && npm run build:es",
+    "prepublish": "npm run check && npm run compile && npm run build",
+    "counter": "cross-env BABEL_ENV=cjs node examples/counter/server.js",
+    "cancellable-counter": "cross-env BABEL_ENV=cjs node examples/cancellable-counter/server.js",
+    "test-counter": "cross-env BABEL_ENV=cjs babel-node examples/counter/test/sagas.js | tap-spec",
+    "shop": "cross-env BABEL_ENV=cjs node examples/shopping-cart/server.js",
+    "test-shop": "cross-env BABEL_ENV=cjs babel-node examples/shopping-cart/test/sagas.js | tap-spec",
+    "async": "cross-env BABEL_ENV=cjs node examples/async/server.js",
+    "test-async": "cross-env BABEL_ENV=cjs babel-node examples/async/test/sagas.js | tap-spec",
+    "real-world": "npm --prefix examples/real-world install examples/real-world && cross-env BABEL_ENV=cjs node --require babel-register examples/real-world/server.js",
     "docs:clean": "rimraf _book",
@@ -56,4 +57,6 @@ "docs:prepare": "gitbook install",
     "babel-preset-es2015": "^6.1.18",
+    "babel-preset-es2015-webpack": "^6.4.1",
     "babel-preset-react": "^6.1.18",
     "babel-preset-stage-2": "^6.1.18",
+    "cross-env": "^1.0.8",
     "eslint": "^2.8.0",
@@ -60,0 +63,0 @@ "express": "^4.13.3",

README.md

@@ -86,2 +86,4 @@ # redux-saga
 }
+
+export default mySaga;
 ```
@@ -88,0 +90,0 @@

src/internal/middleware.js

@@ -29,2 +29,6 @@ import { is, check } from './utils'
 
+  if(options.logger && !is.func(options.logger)) {
+    throw new Error('`options.logger` passed to the Saga middleware is not a function!')
+  }
+
   function sagaMiddleware({getState, dispatch}) {
@@ -40,3 +44,3 @@ runSagaDynamically = runSaga
         getState,
-        options.sagaMonitor,
+        options,
         0,
@@ -43,0 +47,0 @@ saga.name

src/internal/proc.js

@@ -1,2 +0,2 @@
-import { noop, kTrue, is, log, check, deferred, autoInc, remove, TASK, CANCEL, makeIterator } from './utils'
+import { noop, kTrue, is, log as _log, check, deferred, autoInc, remove, TASK, CANCEL, makeIterator } from './utils'
 import asap from './asap'
@@ -100,3 +100,3 @@ import { asEffect } from './io'
   getState = noop,
-  monitor,
+  options={},
   parentEffectId = 0,
@@ -108,2 +108,4 @@ name = 'anonymous',
 
+  const {sagaMonitor, logger} = options
+  const log = logger || _log
   const stdChannel = eventChannel(subscribe)
@@ -258,3 +260,3 @@ /**
     const effectId = nextEffectId()
-    monitor && monitor.effectTriggered({effectId, parentEffectId, label, effect})
+    sagaMonitor && sagaMonitor.effectTriggered({effectId, parentEffectId, label, effect})
 
@@ -276,6 +278,6 @@ /**
       cb.cancel = noop // defensive measure
-      if(monitor) {
+      if(sagaMonitor) {
         isErr ?
-          monitor.effectRejected(effectId, res)
-        : monitor.effectResolved(effectId, res)
+          sagaMonitor.effectRejected(effectId, res)
+        : sagaMonitor.effectResolved(effectId, res)
       }
@@ -308,3 +310,3 @@
 
-      monitor && monitor.effectCancelled(effectId)
+      sagaMonitor && sagaMonitor.effectCancelled(effectId)
     }
@@ -362,3 +364,3 @@
   function resolveIterator(iterator, effectId, name, cb) {
-    proc(iterator, subscribe, dispatch, getState, monitor, effectId, name, cb)
+    proc(iterator, subscribe, dispatch, getState, options, effectId, name, cb)
   }
@@ -478,3 +480,3 @@
     asap.suspend()
-    let task = proc(_iterator, subscribe, dispatch, getState, monitor, effectId, fn.name, (detached ? null : noop))
+    let task = proc(_iterator, subscribe, dispatch, getState, options, effectId, fn.name, (detached ? null : noop))
     if(!detached) {
@@ -481,0 +483,0 @@ if(_iterator._isRunning) {

src/internal/runSaga.js

@@ -9,5 +9,6 @@ import { is, check } from './utils'
     dispatch,
-    getState
-  },
-  monitor
+    getState,
+    sagaMonitor,
+    logger
+  }
 ) {
@@ -22,4 +23,4 @@
     getState,
-    monitor
+    {sagaMonitor, logger}
   )
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

349276

increased by16.75%

Number of package files

56

increased by27.27%

Lines of code

6087

increased by28.28%

Number of lines in readme file

217

increased by0.93%

Worsened metrics

Dev dependency count

27

increased by8%

Number of low supply chain risk alerts

9

increased by50%

No dependency changes