diff --git a/dist/redux-saga.js b/dist/redux-saga.js
index b25535d9b..f52461aaa 100644
--- a/dist/redux-saga.js
+++ b/dist/redux-saga.js
@@ -466,7 +466,11 @@ return /******/ (function(modules) { // webpackBootstrap
 	  var buffer = arguments.length <= 1 || arguments[1] === undefined ? _buffers.buffers.none() : arguments[1];
 	  var matcher = arguments[2];
 
-	  if (arguments.length > 1) (0, _utils.check)(matcher, _utils.is.func, 'Invalid match function passed to eventChannel');
+	  /**
+	    should be if(typeof matcher !== undefined) instead?
+	    see PR #273 for a background discussion
+	  **/
+	  if (arguments.length > 2) (0, _utils.check)(matcher, _utils.is.func, 'Invalid match function passed to eventChannel');
 
 	  var chan = channel(buffer);
 	  var unsubscribe = subscribe(function (input) {
@@ -783,10 +787,10 @@ return /******/ (function(modules) { // webpackBootstrap
 	  fixed: function fixed(limit) {
 	    return arrBuffer(limit, ON_OVERFLOW_THROW);
 	  },
-	  drop: function drop(limit) {
+	  dropping: function dropping(limit) {
 	    return arrBuffer(limit, ON_OVERFLOW_DROP);
 	  },
-	  slide: function slide(limit) {
+	  sliding: function sliding(limit) {
 	    return arrBuffer(limit, ON_OVERFLOW_SLIDE);
 	  }
 	};
@@ -800,7 +804,7 @@ return /******/ (function(modules) { // webpackBootstrap
 	Object.defineProperty(exports, "__esModule", {
 	  value: true
 	});
-	exports.Never = exports.CANCEL = exports.NOT_ITERATOR_ERROR = undefined;
+	exports.TASK_CANCEL = exports.CHANNEL_END = exports.CANCEL = exports.NOT_ITERATOR_ERROR = undefined;
 	exports.default = proc;
 
 	var _utils = __webpack_require__(1);
@@ -828,12 +832,16 @@ return /******/ (function(modules) { // webpackBootstrap
 	var CANCEL = exports.CANCEL = (0, _utils.sym)('cancelPromise');
 
 	var nextEffectId = (0, _utils.autoInc)();
-	var Never = exports.Never = {
+	var CHANNEL_END = exports.CHANNEL_END = {
+	  toString: function toString() {
+	    return '@@redux-saga/CHANNEL_END';
+	  }
+	};
+	var TASK_CANCEL = exports.TASK_CANCEL = {
 	  toString: function toString() {
-	    return '@@redux-saga/Never';
+	    return '@@redux-saga/TASK_CANCEL';
 	  }
 	};
-	Object.freeze(Never);
 
 	var matchers = {
 	  wildcard: function wildcard() {
@@ -885,19 +893,19 @@ return /******/ (function(modules) { // webpackBootstrap
 
 	  function addTask(task) {
 	    tasks.push(task);
-	    task.cont = function (err, res) {
+	    task.cont = function (res, isErr) {
 	      if (completed) return;
 
 	      (0, _utils.remove)(tasks, task);
 	      task.cont = _utils.noop;
-	      if (err) {
+	      if (isErr) {
 	        cancelAll();
-	        cb(err);
+	        cb(res, true);
 	      } else {
 	        if (task === mainTask) result = res;
 	        if (!tasks.length) {
 	          completed = true;
-	          cb(null, result);
+	          cb(result);
 	        }
 	      }
 	    };
@@ -964,7 +972,7 @@ return /******/ (function(modules) { // webpackBootstrap
 	  function cancelMain() {
 	    if (mainTask.isRunning && !mainTask.isCancelled) {
 	      mainTask.isCancelled = true;
-	      next(null, Never);
+	      next(TASK_CANCEL);
 	    }
 	  }
 
@@ -986,7 +994,7 @@ return /******/ (function(modules) { // webpackBootstrap
 	      /**
 	        Ending with a Never result will propagate the Cancellation to all joiners
 	      **/
-	      end(null, Never);
+	      end(TASK_CANCEL);
 	    }
 	  }
 	  /**
@@ -1009,19 +1017,18 @@ return /******/ (function(modules) { // webpackBootstrap
 	    It's a recursive async/continuation function which calls itself
 	    until the generator terminates or throws
 	  **/
-	  function next(error, arg) {
+	  function next(arg, isErr) {
 	    // Preventive measure. If we end up here, then there is really something wrong
 	    if (!mainTask.isRunning) throw new Error('Trying to resume an already finished generator');
 
 	    try {
 	      var result = void 0;
-	      if (error) result = iterator.throw(error);else if (arg === Never) {
+	      if (isErr) result = iterator.throw(arg);else if (arg === TASK_CANCEL) {
 	        /**
-	          getting Never autoamtically cancels the main task
+	          getting TASK_CANCEL autoamtically cancels the main task
 	          We can get this value here
 	            - By cancelling the parent task manually
 	          - By joining a Cancelled task
-	          - By taking from a channel that ended using `take` (and not `takem` used to trap End of channels)
 	        **/
 	        mainTask.isCancelled = true;
 	        /**
@@ -1032,7 +1039,10 @@ return /******/ (function(modules) { // webpackBootstrap
 	          If this Generator has a `return` method then invokes it
 	          Thill will jump to the finally block
 	        **/
-	        result = _utils.is.func(iterator.return) ? iterator.return(Never) : { done: true, value: Never };
+	        result = _utils.is.func(iterator.return) ? iterator.return(TASK_CANCEL) : { done: true, value: TASK_CANCEL };
+	      } else if (arg === CHANNEL_END) {
+	        // We get CHANNEL_END by taking from a channel that ended using `take` (and not `takem` used to trap End of channels)
+	        result = _utils.is.func(iterator.return) ? iterator.return() : { done: true };
 	      } else result = iterator.next(arg);
 
 	      if (!result.done) {
@@ -1042,31 +1052,32 @@ return /******/ (function(modules) { // webpackBootstrap
 	          This Generator has ended, terminate the main task and notify the fork queue
 	        **/
 	        mainTask.isMainRunning = false;
-	        mainTask.cont && mainTask.cont(null, result.value);
+	        mainTask.cont && mainTask.cont(result.value);
 	      }
 	    } catch (error) {
 	      if (mainTask.isCancelled) (0, _utils.log)('error', 'uncaught at ' + name, error.message);
 	      mainTask.isMainRunning = false;
-	      mainTask.cont(error);
+	      mainTask.cont(error, true);
 	    }
 	  }
 
-	  function end(error, result) {
+	  function end(result, isErr) {
 	    iterator._isRunning = false;
 	    stdChannel.close();
-	    if (!error) {
-	      if (result === Never && _utils.isDev) (0, _utils.log)('info', name + ' has been cancelled', '');
+	    if (!isErr) {
+	      if (result === TASK_CANCEL && _utils.isDev) (0, _utils.log)('info', name + ' has been cancelled', '');
 	      iterator._result = result;
 	      iterator._deferredEnd && iterator._deferredEnd.resolve(result);
 	    } else {
-	      if (error instanceof Error) error.sagaStack = 'at ' + name + ' \n ' + (error.sagaStack || error.message);
-	      if (!task.cont) (0, _utils.log)('error', 'uncaught', error.sagaStack || error.message);
-	      iterator._error = error;
-	      iterator._deferredEnd && iterator._deferredEnd.reject(error);
+	      if (result instanceof Error) result.sagaStack = 'at ' + name + ' \n ' + (result.sagaStack || result.message);
+	      if (!task.cont) (0, _utils.log)('error', 'uncaught', result.sagaStack || result.message);
+	      iterator._error = result;
+	      iterator._isAborted = true;
+	      iterator._deferredEnd && iterator._deferredEnd.reject(result);
 	    }
-	    task.cont && task.cont(error, result);
+	    task.cont && task.cont(result, isErr);
 	    task.joiners.forEach(function (j) {
-	      return j.cb(error, result);
+	      return j.cb(result, isErr);
 	    });
 	    task.joiners = null;
 	  }
@@ -1086,16 +1097,16 @@ return /******/ (function(modules) { // webpackBootstrap
 	    var effectSettled = void 0;
 
 	    // Completion callback passed to the appropriate effect runner
-	    function currCb(err, res) {
+	    function currCb(res, isErr) {
 	      if (effectSettled) return;
 
 	      effectSettled = true;
 	      cb.cancel = _utils.noop; // defensive measure
 	      if (monitor) {
-	        err ? monitor.effectRejected(effectId, err) : monitor.effectResolved(effectId, res);
+	        isErr ? monitor.effectRejected(effectId, res) : monitor.effectResolved(effectId, res);
 	      }
 
-	      cb(err, res);
+	      cb(res, isErr);
 	    }
 	    // tracks down the current cancel
 	    currCb.cancel = _utils.noop;
@@ -1139,7 +1150,7 @@ return /******/ (function(modules) { // webpackBootstrap
 	      _utils.is.promise(effect) ? resolvePromise(effect, currCb) : _utils.is.iterator(effect) ? resolveIterator(effect, effectId, name, currCb)
 
 	      // declarative effects
-	      : _utils.is.array(effect) ? runParallelEffect(effect, effectId, currCb) : _utils.is.notUndef(data = _io.asEffect.take(effect)) ? runTakeEffect(data, currCb) : _utils.is.notUndef(data = _io.asEffect.put(effect)) ? runPutEffect(data, currCb) : _utils.is.notUndef(data = _io.asEffect.race(effect)) ? runRaceEffect(data, effectId, currCb) : _utils.is.notUndef(data = _io.asEffect.call(effect)) ? runCallEffect(data, effectId, currCb) : _utils.is.notUndef(data = _io.asEffect.cps(effect)) ? runCPSEffect(data, currCb) : _utils.is.notUndef(data = _io.asEffect.fork(effect)) ? runForkEffect(data, effectId, currCb) : _utils.is.notUndef(data = _io.asEffect.join(effect)) ? runJoinEffect(data, currCb) : _utils.is.notUndef(data = _io.asEffect.cancel(effect)) ? runCancelEffect(data, currCb) : _utils.is.notUndef(data = _io.asEffect.select(effect)) ? runSelectEffect(data, currCb) : _utils.is.notUndef(data = _io.asEffect.actionChannel(effect)) ? runChannelEffect(data, currCb) : _utils.is.notUndef(data = _io.asEffect.cancelled(effect)) ? runCancelledEffect(data, currCb) : /* anything else returned as is        */currCb(null, effect)
+	      : _utils.is.array(effect) ? runParallelEffect(effect, effectId, currCb) : _utils.is.notUndef(data = _io.asEffect.take(effect)) ? runTakeEffect(data, currCb) : _utils.is.notUndef(data = _io.asEffect.put(effect)) ? runPutEffect(data, currCb) : _utils.is.notUndef(data = _io.asEffect.race(effect)) ? runRaceEffect(data, effectId, currCb) : _utils.is.notUndef(data = _io.asEffect.call(effect)) ? runCallEffect(data, effectId, currCb) : _utils.is.notUndef(data = _io.asEffect.cps(effect)) ? runCPSEffect(data, currCb) : _utils.is.notUndef(data = _io.asEffect.fork(effect)) ? runForkEffect(data, effectId, currCb) : _utils.is.notUndef(data = _io.asEffect.join(effect)) ? runJoinEffect(data, currCb) : _utils.is.notUndef(data = _io.asEffect.cancel(effect)) ? runCancelEffect(data, currCb) : _utils.is.notUndef(data = _io.asEffect.select(effect)) ? runSelectEffect(data, currCb) : _utils.is.notUndef(data = _io.asEffect.actionChannel(effect)) ? runChannelEffect(data, currCb) : _utils.is.notUndef(data = _io.asEffect.cancelled(effect)) ? runCancelledEffect(data, currCb) : /* anything else returned as is        */currCb(effect)
 	    );
 	  }
 
@@ -1148,10 +1159,8 @@ return /******/ (function(modules) { // webpackBootstrap
 	    if (typeof cancelPromise === 'function') {
 	      cb.cancel = cancelPromise;
 	    }
-	    promise.then(function (result) {
-	      return cb(null, result);
-	    }, function (error) {
-	      return cb(error);
+	    promise.then(cb, function (error) {
+	      return cb(error, true);
 	    });
 	  }
 
@@ -1166,12 +1175,12 @@ return /******/ (function(modules) { // webpackBootstrap
 
 	    channel = channel || stdChannel;
 	    var takeCb = function takeCb(inp) {
-	      return inp instanceof Error ? cb(inp) : inp === _channel.END && !maybe ? cb(null, Never) : cb(null, inp);
+	      return inp instanceof Error ? cb(inp, true) : inp === _channel.END && !maybe ? cb(CHANNEL_END) : cb(inp);
 	    };
 	    try {
 	      channel.take(takeCb, matcher(pattern));
 	    } catch (err) {
-	      return cb(err);
+	      return cb(err, true);
 	    }
 	    cb.cancel = takeCb.cancel;
 	  }
@@ -1191,13 +1200,13 @@ return /******/ (function(modules) { // webpackBootstrap
 	      try {
 	        result = (channel ? channel.put : dispatch)(action);
 	      } catch (error) {
-	        return cb(error);
+	        return cb(error, true);
 	      }
 
 	      if (_utils.is.promise(result)) {
 	        resolvePromise(result, cb);
 	      } else {
-	        return cb(null, result);
+	        return cb(result);
 	      }
 	    });
 	    // Put effects are non cancellables
@@ -1213,9 +1222,9 @@ return /******/ (function(modules) { // webpackBootstrap
 	    try {
 	      result = fn.apply(context, args);
 	    } catch (error) {
-	      return cb(error);
+	      return cb(error, true);
 	    }
-	    return _utils.is.promise(result) ? resolvePromise(result, cb) : _utils.is.iterator(result) ? resolveIterator(result, effectId, fn.name, cb) : cb(null, result);
+	    return _utils.is.promise(result) ? resolvePromise(result, cb) : _utils.is.iterator(result) ? resolveIterator(result, effectId, fn.name, cb) : cb(result);
 	  }
 
 	  function runCPSEffect(_ref4, cb) {
@@ -1228,9 +1237,11 @@ return /******/ (function(modules) { // webpackBootstrap
 
 	    // catch synchronous failures; see #152
 	    try {
-	      fn.apply(context, args.concat(cb));
+	      fn.apply(context, args.concat(function (err, res) {
+	        return _utils.is.undef(err) ? cb(res) : cb(err, true);
+	      }));
 	    } catch (error) {
-	      return cb(error);
+	      return cb(error, true);
 	    }
 	  }
 
@@ -1281,11 +1292,13 @@ return /******/ (function(modules) { // webpackBootstrap
 	        }());
 	      }
 
-	    var task = proc(_iterator, subscribe, dispatch, getState, monitor, effectId, fn.name, detached ? null : _utils.noop);
-	    if (!detached) {
-	      if (_iterator._isRunning) taskQueue.addTask(task);else if (_iterator._error) return cb(_iterator._error);
-	    }
-	    cb(null, task);
+	    (0, _asap2.default)(function () {
+	      var task = proc(_iterator, subscribe, dispatch, getState, monitor, effectId, fn.name, detached ? null : _utils.noop);
+	      if (!detached) {
+	        if (_iterator._isRunning) taskQueue.addTask(task);else if (_iterator._error) return cb(_iterator._error, true);
+	      }
+	      cb(task);
+	    });
 	    // Fork effects are non cancellables
 	  }
 
@@ -1299,7 +1312,7 @@ return /******/ (function(modules) { // webpackBootstrap
 	        t.joiners.push(joiner);
 	      })();
 	    } else {
-	      cb(t.error(), t.result());
+	      t.isAborted() ? cb(t.error(), true) : cb(t.result());
 	    }
 	  }
 
@@ -1313,8 +1326,7 @@ return /******/ (function(modules) { // webpackBootstrap
 
 	  function runParallelEffect(effects, effectId, cb) {
 	    if (!effects.length) {
-	      cb(null, []);
-	      return;
+	      return cb([]);
 	    }
 
 	    var completedCount = 0;
@@ -1324,16 +1336,16 @@ return /******/ (function(modules) { // webpackBootstrap
 	    function checkEffectEnd() {
 	      if (completedCount === results.length) {
 	        completed = true;
-	        cb(null, results);
+	        cb(results);
 	      }
 	    }
 
 	    var childCbs = effects.map(function (eff, idx) {
-	      var chCbAtIdx = function chCbAtIdx(err, res) {
+	      var chCbAtIdx = function chCbAtIdx(res, isErr) {
 	        if (completed) return;
-	        if (err || res === _channel.END || res === Never) {
+	        if (isErr || res === _channel.END || res === CHANNEL_END || res === TASK_CANCEL) {
 	          cb.cancel();
-	          err ? cb(err) : cb(null, res);
+	          cb(res, isErr);
 	        } else {
 	          results[idx] = res;
 	          completedCount++;
@@ -1364,17 +1376,17 @@ return /******/ (function(modules) { // webpackBootstrap
 	    var childCbs = {};
 
 	    keys.forEach(function (key) {
-	      var chCbAtKey = function chCbAtKey(err, res) {
+	      var chCbAtKey = function chCbAtKey(res, isErr) {
 	        if (completed) return;
 
-	        if (err) {
+	        if (isErr) {
 	          // Race Auto cancellation
 	          cb.cancel();
-	          cb(err);
-	        } else if (res !== _channel.END && res !== Never) {
+	          cb(res, true);
+	        } else if (res !== _channel.END && res !== CHANNEL_END && res !== TASK_CANCEL) {
 	          cb.cancel();
 	          completed = true;
-	          cb(null, _defineProperty({}, key, res));
+	          cb(_defineProperty({}, key, res));
 	        }
 	      };
 	      chCbAtKey.cancel = _utils.noop;
@@ -1401,9 +1413,9 @@ return /******/ (function(modules) { // webpackBootstrap
 
 	    try {
 	      var state = selector.apply(undefined, [getState()].concat(_toConsumableArray(args)));
-	      cb(null, state);
+	      cb(state);
 	    } catch (error) {
-	      cb(error);
+	      cb(error, true);
 	    }
 	  }
 
@@ -1413,11 +1425,11 @@ return /******/ (function(modules) { // webpackBootstrap
 
 	    var match = matcher(pattern);
 	    match.pattern = pattern;
-	    cb(null, (0, _channel.eventChannel)(subscribe, buffer || _buffers.buffers.fixed(), match));
+	    cb((0, _channel.eventChannel)(subscribe, buffer || _buffers.buffers.fixed(), match));
 	  }
 
 	  function runCancelledEffect(data, cb) {
-	    cb(null, !!mainTask.isCancelled);
+	    cb(!!mainTask.isCancelled);
 	  }
 
 	  function newTask(id, name, iterator, cont) {
@@ -1435,6 +1447,8 @@ return /******/ (function(modules) { // webpackBootstrap
 	      return iterator._isRunning;
 	    }), _defineProperty(_ref8, 'isCancelled', function isCancelled() {
 	      return iterator._isCancelled;
+	    }), _defineProperty(_ref8, 'isAborted', function isAborted() {
+	      return iterator._isAborted;
 	    }), _defineProperty(_ref8, 'result', function result() {
 	      return iterator._result;
 	    }), _defineProperty(_ref8, 'error', function error() {
diff --git a/dist/redux-saga.min.js b/dist/redux-saga.min.js
index 959a63003..bddf798c5 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 u=t[r]={exports:{},id:r,loaded:!1};return e[r].call(u.exports,u,u.exports,n),u.loaded=!0,u.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 u(e){return e&&e.__esModule?e:{"default":e}}Object.defineProperty(n,"__esModule",{value:!0}),n.utils=n.effects=n.delay=n.takeLatest=n.takeEvery=n.buffers=n.channel=n.eventChannel=n.END=n.CANCEL=n.runSaga=void 0;var o=t(9);Object.defineProperty(n,"runSaga",{enumerable:!0,get:function(){return o.runSaga}});var a=t(5);Object.defineProperty(n,"CANCEL",{enumerable:!0,get:function(){return a.CANCEL}});var i=t(2);Object.defineProperty(n,"END",{enumerable:!0,get:function(){return i.END}}),Object.defineProperty(n,"eventChannel",{enumerable:!0,get:function(){return i.eventChannel}}),Object.defineProperty(n,"channel",{enumerable:!0,get:function(){return i.channel}});var c=t(4);Object.defineProperty(n,"buffers",{enumerable:!0,get:function(){return c.buffers}});var f=t(10);Object.defineProperty(n,"takeEvery",{enumerable:!0,get:function(){return f.takeEvery}}),Object.defineProperty(n,"takeLatest",{enumerable:!0,get:function(){return f.takeLatest}});var l=t(1);Object.defineProperty(n,"delay",{enumerable:!0,get:function(){return l.delay}});var s=t(8),d=u(s),v=t(6),p=r(v),h=t(11),g=r(h);n.default=d.default,n.effects=p,n.utils=g},function(e,n,t){(function(e){"use strict";function t(e,n,t){return n in e?Object.defineProperty(e,n,{value:t,enumerable:!0,configurable:!0,writable:!0}):e[n]=t,e}function r(e){return e}function u(e,n,t){if(!n(e))throw new Error(t)}function o(e,n){var t=e.indexOf(n);t>=0&&e.splice(t,1)}function a(){var e=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],n=v({},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;e>t;t++)n.push(a());return n}function c(e){var n=arguments.length<=1||void 0===arguments[1]?!0:arguments[1];return new Promise(function(t){return setTimeout(function(){return t(n)},e)})}function f(){var e,n=!0,r=void 0,u=void 0;return e={},t(e,h,!0),t(e,"isRunning",function(){return n}),t(e,"result",function(){return r}),t(e,"error",function(){return u}),t(e,"setRunning",function(e){return n=e}),t(e,"setResult",function(e){return r=e}),t(e,"setError",function(e){return u=e}),e}function l(){var e=arguments.length<=0||void 0===arguments[0]?0:arguments[0];return function(){return++e}}function s(e){var n=arguments.length<=1||void 0===arguments[1]?b:arguments[1],t=arguments.length<=2||void 0===arguments[2]?"":arguments[2],r={name:t,next:e,"throw":n};return"undefined"!=typeof Symbol&&(r[Symbol.iterator]=function(){return r}),r}function d(e,n,t){"undefined"==typeof window?console.log("redux-saga "+e+": "+n+"\n"+(t&&t.stack||t)):console[e].call(console,n,t)}Object.defineProperty(n,"__esModule",{value:!0});var v=Object.assign||function(e){for(var n=1;n<arguments.length;n++){var t=arguments[n];for(var r in t)Object.prototype.hasOwnProperty.call(t,r)&&(e[r]=t[r])}return e};n.ident=r,n.check=u,n.remove=o,n.deferred=a,n.arrayOfDeffered=i,n.delay=c,n.createMockTask=f,n.autoInc=l,n.makeIterator=s,n.log=d;var p=n.sym=function(e){return"@@redux-saga/"+e},h=n.TASK=p("TASK"),g=(n.MATCH=p("MATCH"),n.konst=function(e){return function(){return e}}),y=(n.kTrue=g(!0),n.kFalse=g(!1),n.noop=function(){},n.isDev="undefined"!=typeof e&&e.env&&!1,n.is={undef:function(e){return null===e||void 0===e},notUndef:function(e){return null!==e&&void 0!==e},func:function(e){return"function"==typeof e},number:function(e){return"number"==typeof e},array:Array.isArray,promise:function(e){return e&&y.func(e.then)},iterator:function(e){return e&&y.func(e.next)&&y.func(e.throw)},task:function(e){return e&&e[h]},take:function(e){return e&&y.func(e.take)},put:function(e){return e&&y.func(e.put)},observable:function(e){return e&&y.func(e.subscribe)},buffer:function(e){return e&&y.func(e.isEmpty)&&y.func(e.take)&&y.func(e.put)},pattern:function(e){return e&&("string"==typeof e||y.func(e)||y.array(e))}}),b=function(e){throw e};n.internalErr=function(e){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: "+e+"\n")}}).call(n,t(12))},function(e,n,t){"use strict";function r(){function e(e){return t.push(e),function(){return(0,a.remove)(t,e)}}function n(e){for(var n=t.slice(),r=0,u=n.length;u>r;r++)n[r](e)}var t=[];return{subscribe:e,emit:n}}function u(e){function n(){if(o&&s.length)throw(0,a.internalErr)("Can not have a closed channel with pending takers");if(s.length&&!e.isEmpty())throw(0,a.internalErr)("Can not have pedning takers with non empty buffer")}function t(t){if(n(),(0,a.check)(t,a.is.notUndef,l),!o)if(s.length)for(var r=0;r<s.length;r++){var u=s[r];if(!u[a.MATCH]||u[a.MATCH](t))return s.splice(r,1),u(t)}else e.put(t)}function r(t,r){n(),(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&&e.isEmpty()?t(c):e.isEmpty()?(s.push(t),t.cancel=function(){return(0,a.remove)(s,t)}):t(e.take())}function u(){if(n(),!o&&(o=!0,s.length)){var e=s;s=[];for(var t=0,r=e.length;r>t;t++)e[t](c);s=[]}}var o=!1,s=[];return arguments.length>0?(0,a.check)(e,a.is.buffer,f):e=i.buffers.fixed(),{take:r,put:t,close:u,get __takers__(){return s},get __closed__(){return o}}}function o(e){var n=arguments.length<=1||void 0===arguments[1]?i.buffers.none():arguments[1],t=arguments[2];arguments.length>1&&(0,a.check)(t,a.is.func,"Invalid match function passed to eventChannel");var r=u(n),o=e(function(e){e===c?r.close():t&&!t(e)||r.put(e)});return{take:r.take,close:function(){r.__closed__||(r.close(),o())}}}Object.defineProperty(n,"__esModule",{value:!0}),n.UNDEFINED_INPUT_ERROR=n.INVALID_BUFFER=n.END=void 0,n.emitter=r,n.channel=u,n.eventChannel=o;var a=t(1),i=t(4),c=n.END={type:"@@redux-saga/CHANNEL_END"},f=n.INVALID_BUFFER="invalid buffer passed to channel factory function",l=n.UNDEFINED_INPUT_ERROR="\n  Saga was provided with an undefined action\n  Hints :\n  - check that your Action Creator returns a non undefined value\n  - if the Saga was started using runSaga, check that your subscribe source provides the action to its listeners\n"},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 u(e,n){if(arguments.length>=2)(0,k.check)(e,k.is.notUndef,"take(channel, pattern): channel is undefined"),(0,k.check)(e,k.is.take,"take(channel, pattern): argument "+e+" is not a valid channel (channel argument must have a take method)"),(0,k.check)(n,k.is.notUndef,"take(channel, pattern): pattern is undefined"),(0,k.check)(n,k.is.pattern,"take(channel, pattern): argument "+n+" is not a valid pattern (pattern must be String | Function: a => boolean | Array<String>)");else if(1===arguments.length)if((0,k.check)(e,k.is.notUndef,"take(patternOrChannel): undefined argument"),k.is.take(e))n="*";else{if(!k.is.pattern(e))throw new Error("take(patternOrChannel): argument "+e+" is not valid channel or a valid pattern");n=e,e=null}else n="*";return x(j,{channel:e,pattern:n})}function o(){var e=u.apply(void 0,arguments);return e[j].maybe=!0,e}function a(e,n){return arguments.length>1?((0,k.check)(e,k.is.notUndef,"put(channel, action): argument channel is undefined"),(0,k.check)(e,k.is.put,"put(channel, action): argument "+e+" is not a valid channel (channel argument must have a put method)"),(0,k.check)(n,k.is.notUndef,"put(channel, action): argument action is undefined")):((0,k.check)(e,k.is.notUndef,"put(action): argument action is undefined"),n=e,e=null),x(O,{channel:e,action:n})}function i(e){return x(_,e)}function c(e,n,t){(0,k.check)(n,k.is.notUndef,e+": argument fn is undefined");var r=null;if(k.is.array(n)){var u=n,o=m(u,2);r=o[0],n=o[1]}else if(n.fn){var a=n;r=a.context,n=a.fn}return(0,k.check)(n,k.is.func,e+": argument "+n+" is not a function"),{context:r,fn:n,args:t}}function f(e){for(var n=arguments.length,t=Array(n>1?n-1:0),r=1;n>r;r++)t[r-1]=arguments[r];return x(w,c("call",e,t))}function l(e,n){var t=arguments.length<=2||void 0===arguments[2]?[]:arguments[2];return x(w,c("apply",{context:e,fn:n},t))}function s(e){for(var n=arguments.length,t=Array(n>1?n-1:0),r=1;n>r;r++)t[r-1]=arguments[r];return x(C,c("cps",e,t))}function d(e){for(var n=arguments.length,t=Array(n>1?n-1:0),r=1;n>r;r++)t[r-1]=arguments[r];return x(A,c("fork",e,t))}function v(e){for(var n=arguments.length,t=Array(n>1?n-1:0),r=1;n>r;r++)t[r-1]=arguments[r];var u=d.apply(void 0,[e].concat(t));return u[A].detached=!0,u}function p(e){if((0,k.check)(e,k.is.notUndef,"join(task): argument task is undefined"),!M(e))throw new Error("join(task): argument "+e+" is not a valid Task object \n(HINT: if you are getting this errors in tests, consider using createMockTask from redux-saga/utils)");return x(P,e)}function h(e){if((0,k.check)(e,k.is.notUndef,"cancel(task): argument task is undefined"),!M(e))throw new Error("cancel(task): argument "+e+" is not a valid Task object \n(HINT: if you are getting this errors in tests, consider using createMockTask from redux-saga/utils)");return x(T,e)}function g(e){for(var n=arguments.length,t=Array(n>1?n-1:0),r=1;n>r;r++)t[r-1]=arguments[r];return 0===arguments.length?e=k.ident:((0,k.check)(g,k.is.notUndef,"select(selector,[...]): argument selector is undefined"),(0,k.check)(e,k.is.func,"select(selector,[...]): argument "+e+" is not a function")),x(R,{selector:e,args:t})}function y(e,n){return(0,k.check)(e,k.is.notUndef,"actionChannel(pattern,...): argument pattern is undefined"),arguments.length>1&&((0,k.check)(n,k.is.notUndef,"actionChannel(pattern, buffer): argument buffer is undefined"),(0,k.check)(n,k.is.notUndef,"actionChannel(pattern, buffer): argument "+n+" is not a valid buffer")),x(S,{pattern:e,buffer:n})}function b(){return x(N,{})}Object.defineProperty(n,"__esModule",{value:!0}),n.asEffect=void 0;var m=function(){function e(e,n){var t=[],r=!0,u=!1,o=void 0;try{for(var a,i=e[Symbol.iterator]();!(r=(a=i.next()).done)&&(t.push(a.value),!n||t.length!==n);r=!0);}catch(c){u=!0,o=c}finally{try{!r&&i.return&&i.return()}finally{if(u)throw o}}return t}return function(n,t){if(Array.isArray(n))return n;if(Symbol.iterator in Object(n))return e(n,t);throw new TypeError("Invalid attempt to destructure non-iterable instance")}}();n.take=u,n.takem=o,n.put=a,n.race=i,n.call=f,n.apply=l,n.cps=s,n.fork=d,n.spawn=v,n.join=p,n.cancel=h,n.select=g,n.actionChannel=y,n.cancelled=b;var k=t(1),E=(0,k.sym)("IO"),j="TAKE",O="PUT",_="RACE",w="CALL",C="CPS",A="FORK",P="JOIN",T="CANCEL",R="SELECT",S="ACTION_CHANNEL",N="CANCELLED",x=function(e,n){var t;return t={},r(t,E,!0),r(t,e,n),t},M=function(e){return e[k.TASK]};n.asEffect={take:function(e){return e&&e[E]&&e[j]},put:function(e){return e&&e[E]&&e[O]},race:function(e){return e&&e[E]&&e[_]},call:function(e){return e&&e[E]&&e[w]},cps:function(e){return e&&e[E]&&e[C]},fork:function(e){return e&&e[E]&&e[A]},join:function(e){return e&&e[E]&&e[P]},cancel:function(e){return e&&e[E]&&e[T]},select:function(e){return e&&e[E]&&e[R]},actionChannel:function(e){return e&&e[E]&&e[S]},cancelled:function(e){return e&&e[E]&&e[N]}}},function(e,n,t){"use strict";function r(){var e=arguments.length<=0||void 0===arguments[0]?1/0:arguments[0],n=arguments[1],t=[];return{isEmpty:function(){return!t.length},put:function(r){if(t.length<e)t.push(r);else switch(n){case a:throw new Error(o);case c:t.shift(),t.push(r)}},take:function(){return t.shift()}}}Object.defineProperty(n,"__esModule",{value:!0}),n.buffers=n.BUFFER_OVERFLOW=void 0;var u=t(1),o=n.BUFFER_OVERFLOW="Channel's Buffer overflow!",a=1,i=2,c=3,f={isEmpty:u.kTrue,put:u.noop,take:u.noop};n.buffers={none:function(){return f},fixed:function(e){return r(e,a)},drop:function(e){return r(e,i)},slide:function(e){return r(e,c)}}},function(e,n,t){"use strict";function r(e){return e&&e.__esModule?e:{"default":e}}function u(e,n){for(var t in n){var r=n[t];r.configurable=r.enumerable=!0,"value"in r&&(r.writable=!0),Object.defineProperty(e,t,r)}return e}function o(e){if(Array.isArray(e)){for(var n=0,t=Array(e.length);n<e.length;n++)t[n]=e[n];return t}return Array.from(e)}function a(e,n,t){return n in e?Object.defineProperty(e,n,{value:t,enumerable:!0,configurable:!0,writable:!0}):e[n]=t,e}function i(e){return("*"===e?k.wildcard:l.is.array(e)?k.array:l.is.func(e)?k.predicate:k.default)(e)}function c(e,n,t){function r(e){o.push(e),e.cont=function(r,c){i||((0,l.remove)(o,e),e.cont=l.noop,r?(u(),t(r)):(e===n&&(a=c),o.length||(i=!0,t(null,a))))}}function u(){i||(i=!0,o.forEach(function(e){e.cont=l.noop,e.cancel()}),o=[])}var o=[],a=void 0,i=!1;return r(n),{addTask:r,cancelAll:u,getTasks:function(){return o},taskNames:function(){return o.map(function(e){return e.name})}}}function f(e){function n(){W.isRunning&&!W.isCancelled&&(W.isCancelled=!0,r(null,m))}function t(){e._isRunning&&!e._isCancelled&&(e._isCancelled=!0,Y.cancelAll(),s(null,m))}function r(n,t){if(!W.isRunning)throw new Error("Trying to resume an already finished generator");try{var u=void 0;n?u=e.throw(n):t===m?(W.isCancelled=!0,r.cancel(),u=l.is.func(e.return)?e.return(m):{done:!0,value:m}):u=e.next(t),u.done?(W.isMainRunning=!1,W.cont&&W.cont(null,u.value)):k(u.value,q,"",r)}catch(n){W.isCancelled&&(0,l.log)("error","uncaught at "+H,n.message),W.isMainRunning=!1,W.cont(n)}}function s(n,t){e._isRunning=!1,B.close(),n?(n instanceof Error&&(n.sagaStack="at "+H+" \n "+(n.sagaStack||n.message)),V.cont||(0,l.log)("error","uncaught",n.sagaStack||n.message),e._error=n,e._deferredEnd&&e._deferredEnd.reject(n)):(t===m&&l.isDev&&(0,l.log)("info",H+" has been cancelled",""),e._result=t,e._deferredEnd&&e._deferredEnd.resolve(t)),V.cont&&V.cont(n,t),V.joiners.forEach(function(e){return e.cb(n,t)}),V.joiners=null}function k(e,n){function t(e,n){a||(a=!0,u.cancel=l.noop,F&&(e?F.effectRejected(o,e):F.effectResolved(o,n)),u(e,n))}var r=arguments.length<=2||void 0===arguments[2]?"":arguments[2],u=arguments[3],o=b();F&&F.effectTriggered({effectId:o,parentEffectId:n,label:r,effect:e});var a=void 0;t.cancel=l.noop,u.cancel=function(){if(!a){a=!0;try{t.cancel()}catch(e){(0,l.log)("error","uncaught at "+H,e.message)}t.cancel=l.noop,F&&F.effectCancelled(o)}};var i=void 0;return l.is.promise(e)?E(e,t):l.is.iterator(e)?j(e,o,H,t):l.is.array(e)?R(e,o,t):l.is.notUndef(i=v.asEffect.take(e))?O(i,t):l.is.notUndef(i=v.asEffect.put(e))?_(i,t):l.is.notUndef(i=v.asEffect.race(e))?S(i,o,t):l.is.notUndef(i=v.asEffect.call(e))?w(i,o,t):l.is.notUndef(i=v.asEffect.cps(e))?C(i,t):l.is.notUndef(i=v.asEffect.fork(e))?A(i,o,t):l.is.notUndef(i=v.asEffect.join(e))?P(i,t):l.is.notUndef(i=v.asEffect.cancel(e))?T(i,t):l.is.notUndef(i=v.asEffect.select(e))?N(i,t):l.is.notUndef(i=v.asEffect.actionChannel(e))?x(i,t):l.is.notUndef(i=v.asEffect.cancelled(e))?M(i,t):t(null,e)}function E(e,n){var t=e[y];"function"==typeof t&&(n.cancel=t),e.then(function(e){return n(null,e)},function(e){return n(e)})}function j(e,n,t,r){f(e,I,L,D,F,n,t,r)}function O(e,n){var t=e.channel,r=e.pattern,u=e.maybe;t=t||B;var o=function(e){return e instanceof Error?n(e):e!==p.END||u?n(null,e):n(null,m)};try{t.take(o,i(r))}catch(a){return n(a)}n.cancel=o.cancel}function _(e,n){var t=e.channel,r=e.action;(0,d.default)(function(){var e=void 0;try{e=(t?t.put:L)(r)}catch(u){return n(u)}return l.is.promise(e)?void E(e,n):n(null,e)})}function w(e,n,t){var r=e.context,u=e.fn,o=e.args,a=void 0;try{a=u.apply(r,o)}catch(i){return t(i)}return l.is.promise(a)?E(a,t):l.is.iterator(a)?j(a,n,u.name,t):t(null,a)}function C(e,n){var t=e.context,r=e.fn,u=e.args;try{r.apply(t,u.concat(n))}catch(o){return n(o)}}function A(e,n,t){var r=e.context,u=e.fn,o=e.args,a=e.detached,i=void 0,c=void 0,s=void 0;try{i=u.apply(r,o)}catch(d){if(!a)return t(d);c=d}s=l.is.iterator(i)?i:c?(0,l.makeIterator)(function(){throw c}):(0,l.makeIterator)(function(){var e=void 0,n={done:!1,value:i},t=function(e){return{done:!0,value:e}};return function(r){return e?t(r):(e=!0,n)}}());var v=f(s,I,L,D,F,n,u.name,a?null:l.noop);if(!a)if(s._isRunning)Y.addTask(v);else if(s._error)return t(s._error);t(null,v)}function P(e,n){e.isRunning()?!function(){var t={task:V,cb:n};n.cancel=function(){return(0,l.remove)(e.joiners,t)},e.joiners.push(t)}():n(e.error(),e.result())}function T(e,n){e.isRunning()&&e.cancel(),n()}function R(e,n,t){function r(){u===a.length&&(o=!0,t(null,a))}if(!e.length)return void t(null,[]);var u=0,o=void 0,a=Array(e.length),i=e.map(function(e,n){var i=function(e,i){o||(e||i===p.END||i===m?(t.cancel(),e?t(e):t(null,i)):(a[n]=i,u++,r()))};return i.cancel=l.noop,i});t.cancel=function(){o||(o=!0,i.forEach(function(e){return e.cancel()}))},e.forEach(function(e,t){return k(e,n,t,i[t])})}function S(e,n,t){var r=void 0,u=Object.keys(e),o={};u.forEach(function(e){var n=function(n,u){r||(n?(t.cancel(),t(n)):u!==p.END&&u!==m&&(t.cancel(),r=!0,t(null,a({},e,u))))};n.cancel=l.noop,o[e]=n}),t.cancel=function(){r||(r=!0,u.forEach(function(e){return o[e].cancel()}))},u.forEach(function(t){return k(e[t],n,t,o[t])})}function N(e,n){var t=e.selector,r=e.args;try{var u=t.apply(void 0,[D()].concat(o(r)));n(null,u)}catch(a){n(a)}}function x(e,n){var t=e.pattern,r=e.buffer,u=i(t);u.pattern=t,n(null,(0,p.eventChannel)(I,r||h.buffers.fixed(),u))}function M(e,n){n(null,!!W.isCancelled)}function U(e,n,r,o){var i,c,f;return r._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(r._deferredEnd)return r._deferredEnd.promise;var e=(0,l.deferred)();return r._deferredEnd=e,r._isRunning||(r._error?e.reject(r._error):e.resolve(r._result)),e.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,"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],L=arguments.length<=2||void 0===arguments[2]?l.noop:arguments[2],D=arguments.length<=3||void 0===arguments[3]?l.noop:arguments[3],F=arguments[4],q=arguments.length<=5||void 0===arguments[5]?0:arguments[5],H=arguments.length<=6||void 0===arguments[6]?"anonymous":arguments[6],K=arguments[7];(0,l.check)(e,l.is.iterator,g);var B=(0,p.eventChannel)(I);r.cancel=l.noop;var V=U(q,H,e,K),W={name:H,cancel:n,isRunning:!0},Y=c(H,W,s);return K&&(K.cancel=t),e._isRunning=!0,r(),V}Object.defineProperty(n,"__esModule",{value:!0}),n.Never=n.CANCEL=n.NOT_ITERATOR_ERROR=void 0,n.default=f;var l=t(1),s=t(7),d=r(s),v=t(3),p=t(2),h=t(4),g=n.NOT_ITERATOR_ERROR="proc first argument (Saga function result) must be an iterator",y=n.CANCEL=(0,l.sym)("cancelPromise"),b=(0,l.autoInc)(),m=n.Never={toString:function(){return"@@redux-saga/Never"}};Object.freeze(m);var k={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 e===n.type})}},predicate:function(e){return function(n){return e(n)}}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(3);Object.defineProperty(n,"take",{enumerable:!0,get:function(){return r.take}}),Object.defineProperty(n,"takem",{enumerable:!0,get:function(){return r.takem}}),Object.defineProperty(n,"put",{enumerable:!0,get:function(){return r.put}}),Object.defineProperty(n,"race",{enumerable:!0,get:function(){return r.race}}),Object.defineProperty(n,"call",{enumerable:!0,get:function(){return r.call}}),Object.defineProperty(n,"apply",{enumerable:!0,get:function(){return r.apply}}),Object.defineProperty(n,"cps",{enumerable:!0,get:function(){return r.cps}}),Object.defineProperty(n,"fork",{enumerable:!0,get:function(){return r.fork}}),Object.defineProperty(n,"spawn",{enumerable:!0,get:function(){return r.spawn}}),Object.defineProperty(n,"join",{enumerable:!0,get:function(){return r.join}}),Object.defineProperty(n,"cancel",{enumerable:!0,get:function(){return r.cancel}}),Object.defineProperty(n,"select",{enumerable:!0,get:function(){return r.select}}),Object.defineProperty(n,"actionChannel",{enumerable:!0,get:function(){return r.actionChannel}}),Object.defineProperty(n,"cancelled",{enumerable:!0,get:function(){return r.cancelled}})},function(e,n){"use strict";function t(e){u?r.push(e):(u=!0,r.push(e),t.flush())}Object.defineProperty(n,"__esModule",{value:!0}),n.default=t;var r=[],u=!1;t.suspend=function(){return u=!0},t.flush=function(){for(var e=void 0;e=r.shift();)e();u=!1}},function(e,n,t){"use strict";function r(e){return e&&e.__esModule?e:{"default":e}}function u(){function e(e){function r(e){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)(e.apply(void 0,r),a.subscribe,o,u,n.sagaMonitor,0,e.name)}var u=e.getState,o=e.dispatch;t=r;var a=(0,c.emitter)();return function(e){return function(n){var t=e(n);return a.emit(n),t}}}var n=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],t=void 0;if(o.is.func(n))throw new Error("You passed a function to the Saga middleware. You are likely trying to start a    Saga by directly passing it to the middleware. This is no longer possible starting from 0.10.0.    To run a Saga, you must do it dynamically AFTER mounting the middleware into the store.\n    Example:\n      import createSagaMiddleware from 'redux-saga'\n      ... other imports\n\n      const sagaMiddleware = createSagaMiddleware()\n      const store = createStore(reducer, applyMiddleware(sagaMiddleware))\n      sagaMiddleware.run(saga, ...args)\n    ");return e.run=function(e){for(var n=arguments.length,r=Array(n>1?n-1:0),u=1;n>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)(e,o.is.func,"sagaMiddleware.run(saga, ...args): saga argument must be a Generator function!"),t.apply(void 0,[e].concat(r))},e}Object.defineProperty(n,"__esModule",{value:!0}),n.default=u;var o=t(1),a=t(5),i=r(a),c=t(2)},function(e,n,t){"use strict";function r(e){return e&&e.__esModule?e:{"default":e}}function u(e,n,t){var r=n.subscribe,u=n.dispatch,a=n.getState;return(0,o.check)(e,o.is.iterator,"runSaga must be called on an iterator"),(0,i.default)(e,r,u,a,t)}Object.defineProperty(n,"__esModule",{value:!0}),n.runSaga=u;var o=t(1),a=t(5),i=r(a)},function(e,n,t){"use strict";function r(e,n){function t(n,t){if(o===s)return l;if(t)throw o=s,t;u&&u(n);var r=e[o](),i=a(r,3),c=i[0],f=i[1],d=i[2];return o=c,u=d,o===s?l:f}var r=arguments.length<=2||void 0===arguments[2]?"iterator":arguments[2],u=void 0,o=n;return(0,c.makeIterator)(t,function(e){return t(null,e)},r)}function u(e,n){for(var t=arguments.length,u=Array(t>2?t-2:0),o=2;t>o;o++)u[o-2]=arguments[o];var a={done:!1,value:(0,f.take)(e)},c=function(e){return{done:!1,value:f.fork.apply(void 0,[n].concat(u,[e]))}},l=void 0,d=function(e){return l=e};return r({q1:function(){return["q2",a,d]},q2:function(){return l===i.END?[s]:["q1",c(l)]}},"q1","takeEvery("+String(e)+", "+n.name+")")}function o(e,n){for(var t=arguments.length,u=Array(t>2?t-2:0),o=2;t>o;o++)u[o-2]=arguments[o];var a={done:!1,value:(0,f.take)(e)},c=function(e){return{done:!1,value:f.fork.apply(void 0,[n].concat(u,[e]))}},l=function(e){return{done:!1,value:(0,f.cancel)(e)}},d=void 0,v=void 0,p=function(e){return d=e},h=function(e){return v=e};return r({q1:function(){return["q2",a,h]},q2:function(){return v===i.END?[s]:d?["q3",l(d)]:["q1",c(v),p]},q3:function(){return["q1",c(v),p]}},"q1","takeLatest("+String(e)+", "+n.name+")")}Object.defineProperty(n,"__esModule",{value:!0});var a=function(){function e(e,n){var t=[],r=!0,u=!1,o=void 0;try{for(var a,i=e[Symbol.iterator]();!(r=(a=i.next()).done)&&(t.push(a.value),!n||t.length!==n);r=!0);}catch(c){u=!0,o=c}finally{try{!r&&i.return&&i.return()}finally{if(u)throw o}}return t}return function(n,t){if(Array.isArray(n))return n;if(Symbol.iterator in Object(n))return e(n,t);throw new TypeError("Invalid attempt to destructure non-iterable instance")}}();n.takeEvery=u,n.takeLatest=o;var i=t(2),c=t(1),f=t(3),l={done:!0,value:void 0},s={}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);Object.defineProperty(n,"TASK",{enumerable:!0,get:function(){return r.TASK}}),Object.defineProperty(n,"noop",{enumerable:!0,get:function(){return r.noop}}),Object.defineProperty(n,"is",{enumerable:!0,get:function(){return r.is}}),Object.defineProperty(n,"deferred",{enumerable:!0,get:function(){return r.deferred}}),Object.defineProperty(n,"arrayOfDeffered",{enumerable:!0,get:function(){return r.arrayOfDeffered}}),Object.defineProperty(n,"createMockTask",{enumerable:!0,get:function(){return r.createMockTask}});var u=t(3);Object.defineProperty(n,"asEffect",{enumerable:!0,get:function(){return u.asEffect}})},function(e,n){function t(){f=!1,a.length?c=a.concat(c):l=-1,c.length&&r()}function r(){if(!f){var e=setTimeout(t);f=!0;for(var n=c.length;n;){for(a=c,c=[];++l<n;)a&&a[l].run();l=-1,n=c.length}a=null,f=!1,clearTimeout(e)}}function u(e,n){this.fun=e,this.array=n}function o(){}var a,i=e.exports={},c=[],f=!1,l=-1;i.nextTick=function(e){var n=new Array(arguments.length-1);if(arguments.length>1)for(var t=1;t<arguments.length;t++)n[t-1]=arguments[t];c.push(new u(e,n)),1!==c.length||f||setTimeout(r,0)},u.prototype.run=function(){this.fun.apply(null,this.array)},i.title="browser",i.browser=!0,i.env={},i.argv=[],i.version="",i.versions={},i.on=o,i.addListener=o,i.once=o,i.off=o,i.removeListener=o,i.removeAllListeners=o,i.emit=o,i.binding=function(e){throw new Error("process.binding is not supported")},i.cwd=function(){return"/"},i.chdir=function(e){throw new Error("process.chdir is not supported")},i.umask=function(){return 0}}])});
\ No newline at end of file
+!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.delay=n.takeLatest=n.takeEvery=n.buffers=n.channel=n.eventChannel=n.END=n.CANCEL=n.runSaga=void 0;var u=t(9);Object.defineProperty(n,"runSaga",{enumerable:!0,get:function(){return u.runSaga}});var a=t(5);Object.defineProperty(n,"CANCEL",{enumerable:!0,get:function(){return a.CANCEL}});var i=t(2);Object.defineProperty(n,"END",{enumerable:!0,get:function(){return i.END}}),Object.defineProperty(n,"eventChannel",{enumerable:!0,get:function(){return i.eventChannel}}),Object.defineProperty(n,"channel",{enumerable:!0,get:function(){return i.channel}});var c=t(4);Object.defineProperty(n,"buffers",{enumerable:!0,get:function(){return c.buffers}});var f=t(10);Object.defineProperty(n,"takeEvery",{enumerable:!0,get:function(){return f.takeEvery}}),Object.defineProperty(n,"takeLatest",{enumerable:!0,get:function(){return f.takeLatest}});var s=t(1);Object.defineProperty(n,"delay",{enumerable:!0,get:function(){return s.delay}});var l=t(8),d=o(l),v=t(6),p=r(v),h=t(11),g=r(h);n.default=d.default,n.effects=p,n.utils=g},function(e,n,t){(function(e){"use strict";function t(e,n,t){return n in e?Object.defineProperty(e,n,{value:t,enumerable:!0,configurable:!0,writable:!0}):e[n]=t,e}function r(e){return e}function o(e,n,t){if(!n(e))throw new Error(t)}function u(e,n){var t=e.indexOf(n);t>=0&&e.splice(t,1)}function a(){var e=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],n=v({},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;e>t;t++)n.push(a());return n}function c(e){var n=arguments.length<=1||void 0===arguments[1]?!0:arguments[1];return new Promise(function(t){return setTimeout(function(){return t(n)},e)})}function f(){var e,n=!0,r=void 0,o=void 0;return e={},t(e,h,!0),t(e,"isRunning",function(){return n}),t(e,"result",function(){return r}),t(e,"error",function(){return o}),t(e,"setRunning",function(e){return n=e}),t(e,"setResult",function(e){return r=e}),t(e,"setError",function(e){return o=e}),e}function s(){var e=arguments.length<=0||void 0===arguments[0]?0:arguments[0];return function(){return++e}}function l(e){var n=arguments.length<=1||void 0===arguments[1]?b:arguments[1],t=arguments.length<=2||void 0===arguments[2]?"":arguments[2],r={name:t,next:e,"throw":n};return"undefined"!=typeof Symbol&&(r[Symbol.iterator]=function(){return r}),r}function d(e,n,t){"undefined"==typeof window?console.log("redux-saga "+e+": "+n+"\n"+(t&&t.stack||t)):console[e].call(console,n,t)}Object.defineProperty(n,"__esModule",{value:!0});var v=Object.assign||function(e){for(var n=1;n<arguments.length;n++){var t=arguments[n];for(var r in t)Object.prototype.hasOwnProperty.call(t,r)&&(e[r]=t[r])}return e};n.ident=r,n.check=o,n.remove=u,n.deferred=a,n.arrayOfDeffered=i,n.delay=c,n.createMockTask=f,n.autoInc=s,n.makeIterator=l,n.log=d;var p=n.sym=function(e){return"@@redux-saga/"+e},h=n.TASK=p("TASK"),g=(n.MATCH=p("MATCH"),n.konst=function(e){return function(){return e}}),y=(n.kTrue=g(!0),n.kFalse=g(!1),n.noop=function(){},n.isDev="undefined"!=typeof e&&e.env&&!1,n.is={undef:function(e){return null===e||void 0===e},notUndef:function(e){return null!==e&&void 0!==e},func:function(e){return"function"==typeof e},number:function(e){return"number"==typeof e},array:Array.isArray,promise:function(e){return e&&y.func(e.then)},iterator:function(e){return e&&y.func(e.next)&&y.func(e.throw)},task:function(e){return e&&e[h]},take:function(e){return e&&y.func(e.take)},put:function(e){return e&&y.func(e.put)},observable:function(e){return e&&y.func(e.subscribe)},buffer:function(e){return e&&y.func(e.isEmpty)&&y.func(e.take)&&y.func(e.put)},pattern:function(e){return e&&("string"==typeof e||y.func(e)||y.array(e))}}),b=function(e){throw e};n.internalErr=function(e){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: "+e+"\n")}}).call(n,t(12))},function(e,n,t){"use strict";function r(){function e(e){return t.push(e),function(){return(0,a.remove)(t,e)}}function n(e){for(var n=t.slice(),r=0,o=n.length;o>r;r++)n[r](e)}var t=[];return{subscribe:e,emit:n}}function o(e){function n(){if(u&&l.length)throw(0,a.internalErr)("Can not have a closed channel with pending takers");if(l.length&&!e.isEmpty())throw(0,a.internalErr)("Can not have pedning takers with non empty buffer")}function t(t){if(n(),(0,a.check)(t,a.is.notUndef,s),!u)if(l.length)for(var r=0;r<l.length;r++){var o=l[r];if(!o[a.MATCH]||o[a.MATCH](t))return l.splice(r,1),o(t)}else e.put(t)}function r(t,r){n(),(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),u&&e.isEmpty()?t(c):e.isEmpty()?(l.push(t),t.cancel=function(){return(0,a.remove)(l,t)}):t(e.take())}function o(){if(n(),!u&&(u=!0,l.length)){var e=l;l=[];for(var t=0,r=e.length;r>t;t++)e[t](c);l=[]}}var u=!1,l=[];return arguments.length>0?(0,a.check)(e,a.is.buffer,f):e=i.buffers.fixed(),{take:r,put:t,close:o,get __takers__(){return l},get __closed__(){return u}}}function u(e){var n=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=o(n),u=e(function(e){e===c?r.close():t&&!t(e)||r.put(e)});return{take:r.take,close:function(){r.__closed__||(r.close(),u())}}}Object.defineProperty(n,"__esModule",{value:!0}),n.UNDEFINED_INPUT_ERROR=n.INVALID_BUFFER=n.END=void 0,n.emitter=r,n.channel=o,n.eventChannel=u;var a=t(1),i=t(4),c=n.END={type:"@@redux-saga/CHANNEL_END"},f=n.INVALID_BUFFER="invalid buffer passed to channel factory function",s=n.UNDEFINED_INPUT_ERROR="\n  Saga was provided with an undefined action\n  Hints :\n  - check that your Action Creator returns a non undefined value\n  - if the Saga was started using runSaga, check that your subscribe source provides the action to its listeners\n"},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){if(arguments.length>=2)(0,k.check)(e,k.is.notUndef,"take(channel, pattern): channel is undefined"),(0,k.check)(e,k.is.take,"take(channel, pattern): argument "+e+" is not a valid channel (channel argument must have a take method)"),(0,k.check)(n,k.is.notUndef,"take(channel, pattern): pattern is undefined"),(0,k.check)(n,k.is.pattern,"take(channel, pattern): argument "+n+" is not a valid pattern (pattern must be String | Function: a => boolean | Array<String>)");else if(1===arguments.length)if((0,k.check)(e,k.is.notUndef,"take(patternOrChannel): undefined argument"),k.is.take(e))n="*";else{if(!k.is.pattern(e))throw new Error("take(patternOrChannel): argument "+e+" is not valid channel or a valid pattern");n=e,e=null}else n="*";return x(_,{channel:e,pattern:n})}function u(){var e=o.apply(void 0,arguments);return e[_].maybe=!0,e}function a(e,n){return arguments.length>1?((0,k.check)(e,k.is.notUndef,"put(channel, action): argument channel is undefined"),(0,k.check)(e,k.is.put,"put(channel, action): argument "+e+" is not a valid channel (channel argument must have a put method)"),(0,k.check)(n,k.is.notUndef,"put(channel, action): argument action is undefined")):((0,k.check)(e,k.is.notUndef,"put(action): argument action is undefined"),n=e,e=null),x(j,{channel:e,action:n})}function i(e){return x(O,e)}function c(e,n,t){(0,k.check)(n,k.is.notUndef,e+": argument fn is undefined");var r=null;if(k.is.array(n)){var o=n,u=m(o,2);r=u[0],n=u[1]}else if(n.fn){var a=n;r=a.context,n=a.fn}return(0,k.check)(n,k.is.func,e+": argument "+n+" is not a function"),{context:r,fn:n,args:t}}function f(e){for(var n=arguments.length,t=Array(n>1?n-1:0),r=1;n>r;r++)t[r-1]=arguments[r];return x(w,c("call",e,t))}function s(e,n){var t=arguments.length<=2||void 0===arguments[2]?[]:arguments[2];return x(w,c("apply",{context:e,fn:n},t))}function l(e){for(var n=arguments.length,t=Array(n>1?n-1:0),r=1;n>r;r++)t[r-1]=arguments[r];return x(A,c("cps",e,t))}function d(e){for(var n=arguments.length,t=Array(n>1?n-1:0),r=1;n>r;r++)t[r-1]=arguments[r];return x(C,c("fork",e,t))}function v(e){for(var n=arguments.length,t=Array(n>1?n-1:0),r=1;n>r;r++)t[r-1]=arguments[r];var o=d.apply(void 0,[e].concat(t));return o[C].detached=!0,o}function p(e){if((0,k.check)(e,k.is.notUndef,"join(task): argument task is undefined"),!M(e))throw new Error("join(task): argument "+e+" is not a valid Task object \n(HINT: if you are getting this errors in tests, consider using createMockTask from redux-saga/utils)");return x(P,e)}function h(e){if((0,k.check)(e,k.is.notUndef,"cancel(task): argument task is undefined"),!M(e))throw new Error("cancel(task): argument "+e+" is not a valid Task object \n(HINT: if you are getting this errors in tests, consider using createMockTask from redux-saga/utils)");return x(T,e)}function g(e){for(var n=arguments.length,t=Array(n>1?n-1:0),r=1;n>r;r++)t[r-1]=arguments[r];return 0===arguments.length?e=k.ident:((0,k.check)(g,k.is.notUndef,"select(selector,[...]): argument selector is undefined"),(0,k.check)(e,k.is.func,"select(selector,[...]): argument "+e+" is not a function")),x(N,{selector:e,args:t})}function y(e,n){return(0,k.check)(e,k.is.notUndef,"actionChannel(pattern,...): argument pattern is undefined"),arguments.length>1&&((0,k.check)(n,k.is.notUndef,"actionChannel(pattern, buffer): argument buffer is undefined"),(0,k.check)(n,k.is.notUndef,"actionChannel(pattern, buffer): argument "+n+" is not a valid buffer")),x(S,{pattern:e,buffer:n})}function b(){return x(R,{})}Object.defineProperty(n,"__esModule",{value:!0}),n.asEffect=void 0;var m=function(){function e(e,n){var t=[],r=!0,o=!1,u=void 0;try{for(var a,i=e[Symbol.iterator]();!(r=(a=i.next()).done)&&(t.push(a.value),!n||t.length!==n);r=!0);}catch(c){o=!0,u=c}finally{try{!r&&i.return&&i.return()}finally{if(o)throw u}}return t}return function(n,t){if(Array.isArray(n))return n;if(Symbol.iterator in Object(n))return e(n,t);throw new TypeError("Invalid attempt to destructure non-iterable instance")}}();n.take=o,n.takem=u,n.put=a,n.race=i,n.call=f,n.apply=s,n.cps=l,n.fork=d,n.spawn=v,n.join=p,n.cancel=h,n.select=g,n.actionChannel=y,n.cancelled=b;var k=t(1),E=(0,k.sym)("IO"),_="TAKE",j="PUT",O="RACE",w="CALL",A="CPS",C="FORK",P="JOIN",T="CANCEL",N="SELECT",S="ACTION_CHANNEL",R="CANCELLED",x=function(e,n){var t;return t={},r(t,E,!0),r(t,e,n),t},M=function(e){return e[k.TASK]};n.asEffect={take:function(e){return e&&e[E]&&e[_]},put:function(e){return e&&e[E]&&e[j]},race:function(e){return e&&e[E]&&e[O]},call:function(e){return e&&e[E]&&e[w]},cps:function(e){return e&&e[E]&&e[A]},fork:function(e){return e&&e[E]&&e[C]},join:function(e){return e&&e[E]&&e[P]},cancel:function(e){return e&&e[E]&&e[T]},select:function(e){return e&&e[E]&&e[N]},actionChannel:function(e){return e&&e[E]&&e[S]},cancelled:function(e){return e&&e[E]&&e[R]}}},function(e,n,t){"use strict";function r(){var e=arguments.length<=0||void 0===arguments[0]?1/0:arguments[0],n=arguments[1],t=[];return{isEmpty:function(){return!t.length},put:function(r){if(t.length<e)t.push(r);else switch(n){case a:throw new Error(u);case c:t.shift(),t.push(r)}},take:function(){return t.shift()}}}Object.defineProperty(n,"__esModule",{value:!0}),n.buffers=n.BUFFER_OVERFLOW=void 0;var o=t(1),u=n.BUFFER_OVERFLOW="Channel's Buffer overflow!",a=1,i=2,c=3,f={isEmpty:o.kTrue,put:o.noop,take:o.noop};n.buffers={none:function(){return f},fixed:function(e){return r(e,a)},dropping:function(e){return r(e,i)},sliding:function(e){return r(e,c)}}},function(e,n,t){"use strict";function r(e){return e&&e.__esModule?e:{"default":e}}function o(e,n){for(var t in n){var r=n[t];r.configurable=r.enumerable=!0,"value"in r&&(r.writable=!0),Object.defineProperty(e,t,r)}return e}function u(e){if(Array.isArray(e)){for(var n=0,t=Array(e.length);n<e.length;n++)t[n]=e[n];return t}return Array.from(e)}function a(e,n,t){return n in e?Object.defineProperty(e,n,{value:t,enumerable:!0,configurable:!0,writable:!0}):e[n]=t,e}function i(e){return("*"===e?E.wildcard:s.is.array(e)?E.array:s.is.func(e)?E.predicate:E.default)(e)}function c(e,n,t){function r(e){u.push(e),e.cont=function(r,c){i||((0,s.remove)(u,e),e.cont=s.noop,c?(o(),t(r,!0)):(e===n&&(a=r),u.length||(i=!0,t(a))))}}function o(){i||(i=!0,u.forEach(function(e){e.cont=s.noop,e.cancel()}),u=[])}var u=[],a=void 0,i=!1;return r(n),{addTask:r,cancelAll:o,getTasks:function(){return u},taskNames:function(){return u.map(function(e){return e.name})}}}function f(e){function n(){Y.isRunning&&!Y.isCancelled&&(Y.isCancelled=!0,r(k))}function t(){e._isRunning&&!e._isCancelled&&(e._isCancelled=!0,G.cancelAll(),l(k))}function r(n,t){if(!Y.isRunning)throw new Error("Trying to resume an already finished generator");try{var o=void 0;t?o=e.throw(n):n===k?(Y.isCancelled=!0,r.cancel(),o=s.is.func(e.return)?e.return(k):{done:!0,value:k}):o=n===m?s.is.func(e.return)?e.return():{done:!0}:e.next(n),o.done?(Y.isMainRunning=!1,Y.cont&&Y.cont(o.value)):E(o.value,H,"",r)}catch(u){Y.isCancelled&&(0,s.log)("error","uncaught at "+K,u.message),Y.isMainRunning=!1,Y.cont(u,!0)}}function l(n,t){e._isRunning=!1,V.close(),t?(n instanceof Error&&(n.sagaStack="at "+K+" \n "+(n.sagaStack||n.message)),W.cont||(0,s.log)("error","uncaught",n.sagaStack||n.message),e._error=n,e._isAborted=!0,e._deferredEnd&&e._deferredEnd.reject(n)):(n===k&&s.isDev&&(0,s.log)("info",K+" has been cancelled",""),e._result=n,e._deferredEnd&&e._deferredEnd.resolve(n)),W.cont&&W.cont(n,t),W.joiners.forEach(function(e){return e.cb(n,t)}),W.joiners=null}function E(e,n){function t(e,n){a||(a=!0,o.cancel=s.noop,q&&(n?q.effectRejected(u,e):q.effectResolved(u,e)),o(e,n))}var r=arguments.length<=2||void 0===arguments[2]?"":arguments[2],o=arguments[3],u=b();q&&q.effectTriggered({effectId:u,parentEffectId:n,label:r,effect:e});var a=void 0;t.cancel=s.noop,o.cancel=function(){if(!a){a=!0;try{t.cancel()}catch(e){(0,s.log)("error","uncaught at "+K,e.message)}t.cancel=s.noop,q&&q.effectCancelled(u)}};var i=void 0;return s.is.promise(e)?_(e,t):s.is.iterator(e)?j(e,u,K,t):s.is.array(e)?S(e,u,t):s.is.notUndef(i=v.asEffect.take(e))?O(i,t):s.is.notUndef(i=v.asEffect.put(e))?w(i,t):s.is.notUndef(i=v.asEffect.race(e))?R(i,u,t):s.is.notUndef(i=v.asEffect.call(e))?A(i,u,t):s.is.notUndef(i=v.asEffect.cps(e))?C(i,t):s.is.notUndef(i=v.asEffect.fork(e))?P(i,u,t):s.is.notUndef(i=v.asEffect.join(e))?T(i,t):s.is.notUndef(i=v.asEffect.cancel(e))?N(i,t):s.is.notUndef(i=v.asEffect.select(e))?x(i,t):s.is.notUndef(i=v.asEffect.actionChannel(e))?M(i,t):s.is.notUndef(i=v.asEffect.cancelled(e))?U(i,t):t(e)}function _(e,n){var t=e[y];"function"==typeof t&&(n.cancel=t),e.then(n,function(e){return n(e,!0)})}function j(e,n,t,r){f(e,D,I,F,q,n,t,r)}function O(e,n){var t=e.channel,r=e.pattern,o=e.maybe;t=t||V;var u=function(e){return e instanceof Error?n(e,!0):n(e!==p.END||o?e:m)};try{t.take(u,i(r))}catch(a){return n(a,!0)}n.cancel=u.cancel}function w(e,n){var t=e.channel,r=e.action;(0,d.default)(function(){var e=void 0;try{e=(t?t.put:I)(r)}catch(o){return n(o,!0)}return s.is.promise(e)?void _(e,n):n(e)})}function A(e,n,t){var r=e.context,o=e.fn,u=e.args,a=void 0;try{a=o.apply(r,u)}catch(i){return t(i,!0)}return s.is.promise(a)?_(a,t):s.is.iterator(a)?j(a,n,o.name,t):t(a)}function C(e,n){var t=e.context,r=e.fn,o=e.args;try{r.apply(t,o.concat(function(e,t){return s.is.undef(e)?n(t):n(e,!0)}))}catch(u){return n(u,!0)}}function P(e,n,t){var r=e.context,o=e.fn,u=e.args,a=e.detached,i=void 0,c=void 0,l=void 0;try{i=o.apply(r,u)}catch(v){if(!a)return t(v);c=v}l=s.is.iterator(i)?i:c?(0,s.makeIterator)(function(){throw c}):(0,s.makeIterator)(function(){var e=void 0,n={done:!1,value:i},t=function(e){return{done:!0,value:e}};return function(r){return e?t(r):(e=!0,n)}}()),(0,d.default)(function(){var e=f(l,D,I,F,q,n,o.name,a?null:s.noop);if(!a)if(l._isRunning)G.addTask(e);else if(l._error)return t(l._error,!0);t(e)})}function T(e,n){e.isRunning()?!function(){var t={task:W,cb:n};n.cancel=function(){return(0,s.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===a.length&&(u=!0,t(a))}if(!e.length)return t([]);var o=0,u=void 0,a=Array(e.length),i=e.map(function(e,n){var i=function(e,i){u||(i||e===p.END||e===m||e===k?(t.cancel(),t(e,i)):(a[n]=e,o++,r()))};return i.cancel=s.noop,i});t.cancel=function(){u||(u=!0,i.forEach(function(e){return e.cancel()}))},e.forEach(function(e,t){return E(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)):n!==p.END&&n!==m&&n!==k&&(t.cancel(),r=!0,t(a({},e,n))))};n.cancel=s.noop,u[e]=n}),t.cancel=function(){r||(r=!0,o.forEach(function(e){return u[e].cancel()}))},o.forEach(function(t){return E(e[t],n,t,u[t])})}function x(e,n){var t=e.selector,r=e.args;try{var o=t.apply(void 0,[F()].concat(u(r)));n(o)}catch(a){n(a,!0)}}function M(e,n){var t=e.pattern,r=e.buffer,o=i(t);o.pattern=t,n((0,p.eventChannel)(D,r||h.buffers.fixed(),o))}function U(e,n){n(!!Y.isCancelled)}function L(e,n,r,u){var i,c,f;return r._deferredEnd=null,c={},a(c,s.TASK,!0),a(c,"id",e),a(c,"name",n),i="done",f={},f[i]=f[i]||{},f[i].get=function(){if(r._deferredEnd)return r._deferredEnd.promise;var e=(0,s.deferred)();return r._deferredEnd=e,r._isRunning||(r._error?e.reject(r._error):e.resolve(r._result)),e.promise},a(c,"cont",u),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}),o(c,f),c}var D=arguments.length<=1||void 0===arguments[1]?function(){return s.noop}:arguments[1],I=arguments.length<=2||void 0===arguments[2]?s.noop:arguments[2],F=arguments.length<=3||void 0===arguments[3]?s.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,s.check)(e,s.is.iterator,g);var V=(0,p.eventChannel)(D);r.cancel=s.noop;var W=L(H,K,e,B),Y={name:K,cancel:n,isRunning:!0},G=c(K,Y,l);return B&&(B.cancel=t),e._isRunning=!0,r(),W}Object.defineProperty(n,"__esModule",{value:!0}),n.TASK_CANCEL=n.CHANNEL_END=n.CANCEL=n.NOT_ITERATOR_ERROR=void 0,n.default=f;var s=t(1),l=t(7),d=r(l),v=t(3),p=t(2),h=t(4),g=n.NOT_ITERATOR_ERROR="proc first argument (Saga function result) must be an iterator",y=n.CANCEL=(0,s.sym)("cancelPromise"),b=(0,s.autoInc)(),m=n.CHANNEL_END={toString:function(){return"@@redux-saga/CHANNEL_END"}},k=n.TASK_CANCEL={toString:function(){return"@@redux-saga/TASK_CANCEL"}},E={wildcard:function(){return s.kTrue},"default":function(e){return function(n){return n.type===e}},array:function(e){return function(n){return e.some(function(e){return e===n.type})}},predicate:function(e){return function(n){return e(n)}}}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(3);Object.defineProperty(n,"take",{enumerable:!0,get:function(){return r.take}}),Object.defineProperty(n,"takem",{enumerable:!0,get:function(){return r.takem}}),Object.defineProperty(n,"put",{enumerable:!0,get:function(){return r.put}}),Object.defineProperty(n,"race",{enumerable:!0,get:function(){return r.race}}),Object.defineProperty(n,"call",{enumerable:!0,get:function(){return r.call}}),Object.defineProperty(n,"apply",{enumerable:!0,get:function(){return r.apply}}),Object.defineProperty(n,"cps",{enumerable:!0,get:function(){return r.cps}}),Object.defineProperty(n,"fork",{enumerable:!0,get:function(){return r.fork}}),Object.defineProperty(n,"spawn",{enumerable:!0,get:function(){return r.spawn}}),Object.defineProperty(n,"join",{enumerable:!0,get:function(){return r.join}}),Object.defineProperty(n,"cancel",{enumerable:!0,get:function(){return r.cancel}}),Object.defineProperty(n,"select",{enumerable:!0,get:function(){return r.select}}),Object.defineProperty(n,"actionChannel",{enumerable:!0,get:function(){return r.actionChannel}}),Object.defineProperty(n,"cancelled",{enumerable:!0,get:function(){return r.cancelled}})},function(e,n){"use strict";function t(e){o?r.push(e):(o=!0,r.push(e),t.flush())}Object.defineProperty(n,"__esModule",{value:!0}),n.default=t;var r=[],o=!1;t.suspend=function(){return o=!0},t.flush=function(){for(var e=void 0;e=r.shift();)e();o=!1}},function(e,n,t){"use strict";function r(e){return e&&e.__esModule?e:{"default":e}}function o(){function e(e){function r(e){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)(e.apply(void 0,r),a.subscribe,u,o,n.sagaMonitor,0,e.name)}var o=e.getState,u=e.dispatch;t=r;var a=(0,c.emitter)();return function(e){return function(n){var t=e(n);return a.emit(n),t}}}var n=arguments.length<=0||void 0===arguments[0]?{}:arguments[0],t=void 0;if(u.is.func(n))throw new Error("You passed a function to the Saga middleware. You are likely trying to start a    Saga by directly passing it to the middleware. This is no longer possible starting from 0.10.0.    To run a Saga, you must do it dynamically AFTER mounting the middleware into the store.\n    Example:\n      import createSagaMiddleware from 'redux-saga'\n      ... other imports\n\n      const sagaMiddleware = createSagaMiddleware()\n      const store = createStore(reducer, applyMiddleware(sagaMiddleware))\n      sagaMiddleware.run(saga, ...args)\n    ");return e.run=function(e){for(var n=arguments.length,r=Array(n>1?n-1:0),o=1;n>o;o++)r[o-1]=arguments[o];return(0,u.check)(t,u.is.notUndef,"Before running a Saga, you must mount the Saga middleware on the Store using applyMiddleware"),(0,u.check)(e,u.is.func,"sagaMiddleware.run(saga, ...args): saga argument must be a Generator function!"),t.apply(void 0,[e].concat(r))},e}Object.defineProperty(n,"__esModule",{value:!0}),n.default=o;var u=t(1),a=t(5),i=r(a),c=t(2)},function(e,n,t){"use strict";function r(e){return e&&e.__esModule?e:{"default":e}}function o(e,n,t){var r=n.subscribe,o=n.dispatch,a=n.getState;return(0,u.check)(e,u.is.iterator,"runSaga must be called on an iterator"),(0,i.default)(e,r,o,a,t)}Object.defineProperty(n,"__esModule",{value:!0}),n.runSaga=o;var u=t(1),a=t(5),i=r(a)},function(e,n,t){"use strict";function r(e,n){function t(n,t){if(u===l)return s;if(t)throw u=l,t;o&&o(n);var r=e[u](),i=a(r,3),c=i[0],f=i[1],d=i[2];return u=c,o=d,u===l?s:f}var r=arguments.length<=2||void 0===arguments[2]?"iterator":arguments[2],o=void 0,u=n;return(0,c.makeIterator)(t,function(e){return t(null,e)},r)}function o(e,n){for(var t=arguments.length,o=Array(t>2?t-2:0),u=2;t>u;u++)o[u-2]=arguments[u];var a={done:!1,value:(0,f.take)(e)},c=function(e){return{done:!1,value:f.fork.apply(void 0,[n].concat(o,[e]))}},s=void 0,d=function(e){return s=e};return r({q1:function(){return["q2",a,d]},q2:function(){return s===i.END?[l]:["q1",c(s)]}},"q1","takeEvery("+String(e)+", "+n.name+")")}function u(e,n){for(var t=arguments.length,o=Array(t>2?t-2:0),u=2;t>u;u++)o[u-2]=arguments[u];var a={done:!1,value:(0,f.take)(e)},c=function(e){return{done:!1,value:f.fork.apply(void 0,[n].concat(o,[e]))}},s=function(e){return{done:!1,value:(0,f.cancel)(e)}},d=void 0,v=void 0,p=function(e){return d=e},h=function(e){return v=e};return r({q1:function(){return["q2",a,h]},q2:function(){return v===i.END?[l]:d?["q3",s(d)]:["q1",c(v),p]},q3:function(){return["q1",c(v),p]}},"q1","takeLatest("+String(e)+", "+n.name+")")}Object.defineProperty(n,"__esModule",{value:!0});var a=function(){function e(e,n){var t=[],r=!0,o=!1,u=void 0;try{for(var a,i=e[Symbol.iterator]();!(r=(a=i.next()).done)&&(t.push(a.value),!n||t.length!==n);r=!0);}catch(c){o=!0,u=c}finally{try{!r&&i.return&&i.return()}finally{if(o)throw u}}return t}return function(n,t){if(Array.isArray(n))return n;if(Symbol.iterator in Object(n))return e(n,t);throw new TypeError("Invalid attempt to destructure non-iterable instance")}}();n.takeEvery=o,n.takeLatest=u;var i=t(2),c=t(1),f=t(3),s={done:!0,value:void 0},l={}},function(e,n,t){"use strict";Object.defineProperty(n,"__esModule",{value:!0});var r=t(1);Object.defineProperty(n,"TASK",{enumerable:!0,get:function(){return r.TASK}}),Object.defineProperty(n,"noop",{enumerable:!0,get:function(){return r.noop}}),Object.defineProperty(n,"is",{enumerable:!0,get:function(){return r.is}}),Object.defineProperty(n,"deferred",{enumerable:!0,get:function(){return r.deferred}}),Object.defineProperty(n,"arrayOfDeffered",{enumerable:!0,get:function(){return r.arrayOfDeffered}}),Object.defineProperty(n,"createMockTask",{enumerable:!0,get:function(){return r.createMockTask}});var o=t(3);Object.defineProperty(n,"asEffect",{enumerable:!0,get:function(){return o.asEffect}})},function(e,n){function t(){f=!1,a.length?c=a.concat(c):s=-1,c.length&&r()}function r(){if(!f){var e=setTimeout(t);f=!0;for(var n=c.length;n;){for(a=c,c=[];++s<n;)a&&a[s].run();s=-1,n=c.length}a=null,f=!1,clearTimeout(e)}}function o(e,n){this.fun=e,this.array=n}function u(){}var a,i=e.exports={},c=[],f=!1,s=-1;i.nextTick=function(e){var n=new Array(arguments.length-1);if(arguments.length>1)for(var t=1;t<arguments.length;t++)n[t-1]=arguments[t];c.push(new o(e,n)),1!==c.length||f||setTimeout(r,0)},o.prototype.run=function(){this.fun.apply(null,this.array)},i.title="browser",i.browser=!0,i.env={},i.argv=[],i.version="",i.versions={},i.on=u,i.addListener=u,i.once=u,i.off=u,i.removeListener=u,i.removeAllListeners=u,i.emit=u,i.binding=function(e){throw new Error("process.binding is not supported")},i.cwd=function(){return"/"},i.chdir=function(e){throw new Error("process.chdir is not supported")},i.umask=function(){return 0}}])});
\ No newline at end of file
diff --git a/docs/README.md b/docs/README.md
index 6067d915b..98b931f57 100644
--- a/docs/README.md
+++ b/docs/README.md
@@ -21,6 +21,7 @@
   * [Common Concurrency Patterns](/docs/advanced/Concurrency.md)
   * [Examples of Testing Sagas](/docs/advanced/Testing.md)
   * [Connecting Sagas to external Input/Output](/docs/advanced/UsingRunSaga.md)
+  * [Using Channels](/docs/advanced/Channels.md)
 * [Recipes](/docs/recipes/README.md)
 * [External Resources](/docs/ExternalResources.md)
 * [Troubleshooting](/docs/Troubleshooting.md)
diff --git a/docs/advanced/Channels.md b/docs/advanced/Channels.md
index 9931c690c..1fc8d615f 100644
--- a/docs/advanced/Channels.md
+++ b/docs/advanced/Channels.md
@@ -1,7 +1,7 @@
 ## Using channels
 
 Until now We've used the `take` and `put` effects to communicate with the Redux Store. Channels
-generalize those Effects to communicate with external event sources or between Sagas itself. They can
+generalize those Effects to communicate with external event sources or between Sagas themselves. They can
 also be used to  queue specific actions from the Store.
 
 In this section We'll see
@@ -65,12 +65,12 @@ function* handleRequest(payload) { ... }
 ```
 
 The first thing is to create the action channel. We use `yield actionChannel(pattern)` where pattern is interpreted using
-the same rules we mentioned previously with `take(pattern)`. The difference between the 2 forms is that **`actionChannel` can
-buffer incoming messages if the Saga if not yet ready to take them (e.g. blocked on an API call)**.
+the same rules we mentioned previously with `take(pattern)`. The difference between the 2 forms is that `actionChannel` **can
+buffer incoming messages** if the Saga if not yet ready to take them (e.g. blocked on an API call).
 
 Next thing is the `yield take(requestChan)`. Besides usage with a `pattern` to take specific actions from the Redux Store, `take`
 can also be used with channels (above we created a channel object from specific Redux actions). The `take` will block the Saga until
-a message is disponible on the channel. The take may also resume immediately if there is a message stored in the underlying buffer.
+a message is available on the channel. The take may also resume immediately if there is a message stored in the underlying buffer.
 
 The important thing to note is how we're using a blocking `call`. The Saga will remain blocked until `call(handleRequest)` returns. But
 meanwhile, if other `REQUEST` actions are dispatched while the Saga is still blocked, they will queued internally by `requestChan`. When
@@ -162,7 +162,38 @@ loop inside a `try/finally` block. When the interval terminates, the countdown f
 invoking `listener(END)`. Closing a channel has the effect of terminating all Sagas blocked on a `take` from that channel,
 in our example, terminating the Saga will cause it to jump to its `finally` block (if provided, otherwise the Saga simply terminate).
 
->>Note messages on an eventChannel are not buffered by default. You have to provide a buffer to the eventChannel factory in order
+The subscriber returns an `unsubscribe` function. This is used by the channel to unsubscribe before
+the event source complete. Inside a Saga consuming messages from an event channel, if we want to *exit early*
+before the event source complete (e.g. Saga ha been cancelled) you can call `chan.close()` to close the channel
+and unsubscribe from the source.
+
+for example, we can make our Saga support cancellation
+
+```javascript
+import { take, put, call, cancelled } from 'redux-saga/effects'
+import { eventChannel, END } from 'redux-saga'
+
+// creates an event Channel from an interval of seconds
+function countdown(seconds) { ... }
+
+export function* saga() {
+  const chan = yield call(countdown, value)
+  try {    
+    while(true) {
+      let seconds = yield take(chan)
+      console.log(`countdown: ${seconds}`)
+    }
+  } finally {
+    if(yield cancelled()) {
+      chan.close()
+      console.log('countdown cancelled')
+    }    
+  }
+}
+```
+
+
+>Note messages on an eventChannel are not buffered by default. You have to provide a buffer to the eventChannel factory in order
 to specify buffering strategy for the channel (e.g. eventChannel(subscriber, buffer). See API docs for more infos.
 
 ### Using channels to communicate between Sagas