Attempt to fix redux-saga#152

src/internal/proc.js

@@ -264,7 +264,13 @@ export default function proc(
   }
 
   function runCallEffect({context, fn, args}, effectId, cb) {
-    const result = fn.apply(context, args)
+    let result
+    try {
+      result = fn.apply(context, args)
+    }
+    catch(e) {
+      return cb(e)
+    }
     return (
         is.promise(result)  ? resolvePromise(result, cb)
       : is.iterator(result) ? resolveIterator(result, effectId, fn.name, cb)

test/proc/call.js

@@ -47,3 +47,92 @@ test('processor declarative call handling', assert => {
   }, DELAY)
 
 });
+
+
+
+
+
+test('processor handles failure correctly when parent generator call child generator 1', assert => {
+  assert.plan(1);
+
+  let actual = []
+  const dispatch = v => actual.push(v)
+
+  function fail(message) {
+    throw new Error(message)
+  }
+
+  function* genFnChild() {
+    try {
+      yield io.put("startChild")
+      yield io.call(fail,"child error")
+      yield io.put("success child")
+    }
+    catch (e) {
+      yield io.put("failure child")
+    }
+  }
+
+  function* genFnParent() {
+    try {
+      yield io.put("start parent")
+      yield io.call(genFnChild)
+      yield io.put("success parent")
+    }
+    catch (e) {
+      yield io.put("failure parent")
+    }
+  }
+
+  proc(genFnParent(),undefined,dispatch).done.catch(err => assert.fail(err))
+
+  const expected = ['start parent','startChild','failure child','success parent']
+  setTimeout(() => {
+    assert.deepEqual(actual, expected,"processor dispatches appropriate actions")
+    assert.end()
+  }, DELAY)
+
+});
+
+test('processor handles failure correctly when parent generator call child generator 2', assert => {
+  assert.plan(1);
+
+  let actual = []
+  const dispatch = v => actual.push(v)
+
+  function fail(message) {
+    throw new Error(message)
+  }
+
+  function* genFnChild() {
+    try {
+      yield io.put("startChild")
+      yield io.call(fail,"child error")
+      yield io.put("success child")
+    }
+    catch (e) {
+      yield io.put("failure child")
+      throw e;
+    }
+  }
+
+  function* genFnParent() {
+    try {
+      yield io.put("start parent")
+      yield io.call(genFnChild)
+      yield io.put("success parent")
+    }
+    catch (e) {
+      yield io.put("failure parent")
+    }
+  }
+
+  proc(genFnParent(),undefined,dispatch).done.catch(err => assert.fail(err))
+
+  const expected = ['start parent','startChild','failure child','failure parent']
+  setTimeout(() => {
+    assert.deepEqual(actual, expected,"processor dispatches appropriate actions")
+    assert.end()
+  }, DELAY)
+
+});