handle error

.vscode/settings.json

@@ -67,5 +67,8 @@
       "filename": true,
       "format": "svg"
     }
-  ]
+  ],
+  "editor.codeActionsOnSave": {
+    "source.fixAll.eslint": true
+  }
 }

package.json

@@ -61,4 +61,4 @@
     "ancestorSeparator": " › ",
     "usePathForSuiteName": "true"
   }
-}
+}

src/__tests__/composer.test.js

@@ -28,6 +28,9 @@ describe('Composer to compose functions', () => {
     await delay(5)
     return func3(val)
   }
+  const errorFunc = () => {
+    throw new Error('The Error')
+  }
   it('should take 3 functions as parameters and execute them on a value', async () => {
     const chain = await composer(asyncFunc1, asyncFunc2, asyncFunc3)
     const result = await chain('dude')
@@ -38,7 +41,15 @@ describe('Composer to compose functions', () => {
     const result = await chain('dude')
     expect(result).toBe('DUDE-DUDE!!!-DUDE-DUDE!!!')
   })
+  it('should throw when function errors', async () => {
+    try {
+      const chain = composer(func1, func2, errorFunc, func2)
 
+      await chain('dude')
+    } catch (err) {
+      expect(err.name).toBe('Error')
+    }
+  })
   const heldFunction1 = async (val, other) => {
     await delay(5)
     return func3(`${val}-${other}`)

src/reducer.js

@@ -26,8 +26,12 @@ module.exports = (startValue, ...funcs) =>
         resolve(total)
         return
       }
-      const result = await el.value(total)
-      next(result)
+      try {
+        const result = await el.value(total)
+        next(result)
+      } catch (error) {
+        return reject(error)
+      }
     }
 
     next(startValue)