Marking mainly deprecation warnings as pure which allows for better tree-shaking on them, more can be read here https://iamakulov.com/notes/polished-webpack/

Author: Andarist

dist/redux-saga.js

@@ -718,6 +718,18 @@ function stdChannel(subscribe) {
 var done = { done: true, value: undefined };
 var qEnd = {};
 
+function safeName(patternOrChannel) {
+  if (is.channel(patternOrChannel)) {
+    return 'channel';
+  } else if (Array.isArray(patternOrChannel)) {
+    return String(patternOrChannel.map(function (entry) {
+      return String(entry);
+    }));
+  } else {
+    return String(patternOrChannel);
+  }
+}
+
 function fsmIterator(fsm, q0) {
   var name = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : 'iterator';
 
@@ -751,19 +763,7 @@ function fsmIterator(fsm, q0) {
   }, name, true);
 }
 
-function safeName(patternOrChannel) {
-  if (is.channel(patternOrChannel)) {
-    return 'channel';
-  } else if (Array.isArray(patternOrChannel)) {
-    return String(patternOrChannel.map(function (entry) {
-      return String(entry);
-    }));
-  } else {
-    return String(patternOrChannel);
-  }
-}
-
-function takeEveryHelper(patternOrChannel, worker) {
+function takeEvery$2(patternOrChannel, worker) {
   for (var _len = arguments.length, args = Array(_len > 2 ? _len - 2 : 0), _key = 2; _key < _len; _key++) {
     args[_key - 2] = arguments[_key];
   }
@@ -788,9 +788,9 @@ function takeEveryHelper(patternOrChannel, worker) {
   }, 'q1', 'takeEvery(' + safeName(patternOrChannel) + ', ' + worker.name + ')');
 }
 
-function takeLatestHelper(patternOrChannel, worker) {
-  for (var _len2 = arguments.length, args = Array(_len2 > 2 ? _len2 - 2 : 0), _key2 = 2; _key2 < _len2; _key2++) {
-    args[_key2 - 2] = arguments[_key2];
+function takeLatest$2(patternOrChannel, worker) {
+  for (var _len = arguments.length, args = Array(_len > 2 ? _len - 2 : 0), _key = 2; _key < _len; _key++) {
+    args[_key - 2] = arguments[_key];
   }
 
   var yTake = { done: false, value: take(patternOrChannel) };
@@ -823,9 +823,9 @@ function takeLatestHelper(patternOrChannel, worker) {
   }, 'q1', 'takeLatest(' + safeName(patternOrChannel) + ', ' + worker.name + ')');
 }
 
-function throttleHelper(delayLength, pattern, worker) {
-  for (var _len3 = arguments.length, args = Array(_len3 > 3 ? _len3 - 3 : 0), _key3 = 3; _key3 < _len3; _key3++) {
-    args[_key3 - 3] = arguments[_key3];
+function throttle$2(delayLength, pattern, worker) {
+  for (var _len = arguments.length, args = Array(_len > 3 ? _len - 3 : 0), _key = 3; _key < _len; _key++) {
+    args[_key - 3] = arguments[_key];
   }
 
   var action = void 0,
@@ -866,9 +866,10 @@ function throttleHelper(delayLength, pattern, worker) {
 var deprecationWarning = function deprecationWarning(helperName) {
   return 'import { ' + helperName + ' } from \'redux-saga\' has been deprecated in favor of import { ' + helperName + ' } from \'redux-saga/effects\'.\nThe latter will not work with yield*, as helper effects are wrapped automatically for you in fork effect.\nTherefore yield ' + helperName + ' will return task descriptor to your saga and execute next lines of code.';
 };
-var takeEvery$1 = deprecate(takeEveryHelper, deprecationWarning('takeEvery'));
-var takeLatest$1 = deprecate(takeLatestHelper, deprecationWarning('takeLatest'));
-var throttle$1 = deprecate(throttleHelper, deprecationWarning('throttle'));
+
+var takeEvery$1 = /*#__PURE__*/deprecate(takeEvery$2, /*#__PURE__*/deprecationWarning('takeEvery'));
+var takeLatest$1 = /*#__PURE__*/deprecate(takeLatest$2, /*#__PURE__*/deprecationWarning('takeLatest'));
+var throttle$1 = /*#__PURE__*/deprecate(throttle$2, /*#__PURE__*/deprecationWarning('throttle'));
 
 var IO = sym('IO');
 var TAKE = 'TAKE';
@@ -916,7 +917,7 @@ take.maybe = function () {
   return eff;
 };
 
-var takem = deprecate(take.maybe, updateIncentive('takem', 'take.maybe'));
+var takem = /*#__PURE__*/deprecate(take.maybe, /*#__PURE__*/updateIncentive('takem', 'take.maybe'));
 
 function put(channel, action) {
   if (arguments.length > 1) {
@@ -1092,23 +1093,23 @@ function takeEvery$$1(patternOrChannel, worker) {
     args[_key8 - 2] = arguments[_key8];
   }
 
-  return fork.apply(undefined, [takeEveryHelper, patternOrChannel, worker].concat(args));
+  return fork.apply(undefined, [takeEvery$2, patternOrChannel, worker].concat(args));
 }
 
 function takeLatest$$1(patternOrChannel, worker) {
   for (var _len9 = arguments.length, args = Array(_len9 > 2 ? _len9 - 2 : 0), _key9 = 2; _key9 < _len9; _key9++) {
     args[_key9 - 2] = arguments[_key9];
   }
 
-  return fork.apply(undefined, [takeLatestHelper, patternOrChannel, worker].concat(args));
+  return fork.apply(undefined, [takeLatest$2, patternOrChannel, worker].concat(args));
 }
 
 function throttle$$1(ms, pattern, worker) {
   for (var _len10 = arguments.length, args = Array(_len10 > 3 ? _len10 - 3 : 0), _key10 = 3; _key10 < _len10; _key10++) {
     args[_key10 - 3] = arguments[_key10];
   }
 
-  return fork.apply(undefined, [throttleHelper, ms, pattern, worker].concat(args));
+  return fork.apply(undefined, [throttle$2, ms, pattern, worker].concat(args));
 }
 
 var createAsEffectType = function createAsEffectType(type) {

dist/redux-saga.min.js

@@ -44,7 +44,7 @@ take.maybe = (...args) => {
   return eff
 }
 
-export const takem = deprecate(take.maybe, updateIncentive('takem', 'take.maybe'))
+export const takem = /*#__PURE__*/ deprecate(take.maybe, /*#__PURE__*/ updateIncentive('takem', 'take.maybe'))
 
 export function put(channel, action) {
   if (arguments.length > 1) {

src/internal/io.js

@@ -0,0 +1,38 @@
+import { is, makeIterator } from '../utils'
+
+const done = { done: true, value: undefined }
+export const qEnd = {}
+
+export function safeName(patternOrChannel) {
+  if (is.channel(patternOrChannel)) {
+    return 'channel'
+  } else if (Array.isArray(patternOrChannel)) {
+    return String(patternOrChannel.map(entry => String(entry)))
+  } else {
+    return String(patternOrChannel)
+  }
+}
+
+export default function fsmIterator(fsm, q0, name = 'iterator') {
+  let updateState,
+    qNext = q0
+
+  function next(arg, error) {
+    if (qNext === qEnd) {
+      return done
+    }
+
+    if (error) {
+      qNext = qEnd
+      throw error
+    } else {
+      updateState && updateState(arg)
+      let [q, output, _updateState] = fsm[qNext]()
+      qNext = q
+      updateState = _updateState
+      return qNext === qEnd ? done : output
+    }
+  }
+
+  return makeIterator(next, error => next(null, error), name, true)
+}

src/internal/sagaHelpers.js

@@ -0,0 +1,16 @@
+import takeEveryHelper from './takeEvery'
+import takeLatestHelper from './takeLatest'
+import throttleHelper from './throttle'
+
+import { deprecate } from '../utils'
+
+const deprecationWarning = helperName =>
+  `import { ${helperName} } from 'redux-saga' has been deprecated in favor of import { ${helperName} } from 'redux-saga/effects'.
+The latter will not work with yield*, as helper effects are wrapped automatically for you in fork effect.
+Therefore yield ${helperName} will return task descriptor to your saga and execute next lines of code.`
+
+const takeEvery = /*#__PURE__*/ deprecate(takeEveryHelper, /*#__PURE__*/ deprecationWarning('takeEvery'))
+const takeLatest = /*#__PURE__*/ deprecate(takeLatestHelper, /*#__PURE__*/ deprecationWarning('takeLatest'))
+const throttle = /*#__PURE__*/ deprecate(throttleHelper, /*#__PURE__*/ deprecationWarning('throttle'))
+
+export { takeEvery, takeLatest, throttle, takeEveryHelper, takeLatestHelper, throttleHelper }

src/internal/sagaHelpers/fsmIterator.js

@@ -0,0 +1,24 @@
+import fsmIterator, { qEnd, safeName } from './fsmIterator'
+import { take, fork } from '../io'
+import { END } from '../channel'
+
+export default function takeEvery(patternOrChannel, worker, ...args) {
+  const yTake = { done: false, value: take(patternOrChannel) }
+  const yFork = ac => ({ done: false, value: fork(worker, ...args, ac) })
+
+  let action,
+    setAction = ac => (action = ac)
+
+  return fsmIterator(
+    {
+      q1() {
+        return ['q2', yTake, setAction]
+      },
+      q2() {
+        return action === END ? [qEnd] : ['q1', yFork(action)]
+      },
+    },
+    'q1',
+    `takeEvery(${safeName(patternOrChannel)}, ${worker.name})`,
+  )
+}

src/internal/sagaHelpers/index.js

@@ -0,0 +1,29 @@
+import fsmIterator, { qEnd, safeName } from './fsmIterator'
+import { cancel, take, fork } from '../io'
+import { END } from '../channel'
+
+export default function takeLatest(patternOrChannel, worker, ...args) {
+  const yTake = { done: false, value: take(patternOrChannel) }
+  const yFork = ac => ({ done: false, value: fork(worker, ...args, ac) })
+  const yCancel = task => ({ done: false, value: cancel(task) })
+
+  let task, action
+  const setTask = t => (task = t)
+  const setAction = ac => (action = ac)
+
+  return fsmIterator(
+    {
+      q1() {
+        return ['q2', yTake, setAction]
+      },
+      q2() {
+        return action === END ? [qEnd] : task ? ['q3', yCancel(task)] : ['q1', yFork(action), setTask]
+      },
+      q3() {
+        return ['q1', yFork(action), setTask]
+      },
+    },
+    'q1',
+    `takeLatest(${safeName(patternOrChannel)}, ${worker.name})`,
+  )
+}