Merge pull request #577 from simov/pipeAsyncFunctions

[FEATURE][ADD] pipeAsyncFunctions

snippets/pipeAsyncFunctions.md

@@ -0,0 +1,23 @@
+### pipeAsyncFunctions
+
+Performs left-to-right function composition for asynchronous functions.
+
+Use `Array.reduce()` with the spread operator (`...`) to perform left-to-right function composition using `Promise.then()`.
+The functions can return a combination of: simple values, `Promise`'s, or they can be defined as `async` ones returning through `await`.
+All functions must be unary.
+
+```js
+const pipeAsyncFunctions = (...fns) => arg => fns.reduce((p, f) => p.then(f), Promise.resolve(arg));
+```
+
+```js
+const sum = pipeAsyncFunctions(
+  x => x + 1,
+  x => new Promise(resolve => setTimeout(() => resolve(x + 2), 1000)),
+  x => x + 3,
+  async x => (await x) + 4
+);
+(async () => {
+  console.log(await sum(5)); // 15 (after one second)
+})();
+```

tag_database

@@ -169,6 +169,7 @@ partition:array,object,function
 percentile:math
 pick:object,array
 pickBy:object,array,function
+pipeAsyncFunctions:adapter,function,promise
 pipeFunctions:adapter,function
 pluralize:string
 powerset:math

test/dropElements/dropElements.js

@@ -1,5 +0,0 @@
-const dropWhile = (arr, func) => {
-while (arr.length > 0 && !func(arr[0])) arr = arr.slice(1);
-return arr;
-};
-module.exports = dropWhile

test/dropElements/dropElements.test.js

@@ -1,14 +0,0 @@
-const test = require('tape');
-const dropWhile = require('./dropWhile.js');
-
-test('Testing dropWhile', (t) => {
-  //For more information on all the methods supported by tape
-  //Please go to https://github.com/substack/tape
-  t.true(typeof dropWhile === 'function', 'dropWhile is a Function');
-  t.deepEqual(dropWhile([1, 2, 3, 4], n => n >= 3), [3,4], "Removes elements in an array until the passed function returns true");
-  //t.deepEqual(dropWhile(args..), 'Expected');
-  //t.equal(dropWhile(args..), 'Expected');
-  //t.false(dropWhile(args..), 'Expected');
-  //t.throws(dropWhile(args..), 'Expected');
-  t.end();
-});

test/dropWhile/dropWhile.test.js

@@ -10,4 +10,4 @@ test('Testing dropWhile', (t) => {
   //t.false(dropWhile(args..), 'Expected');
   //t.throws(dropWhile(args..), 'Expected');
   t.end();
-});
+});

test/pipeAsyncFunctions/pipeAsyncFunctions.js

@@ -0,0 +1,2 @@
+const pipeAsyncFunctions = (...fns) => arg => fns.reduce((p, f) => p.then(f), Promise.resolve(arg));
+module.exports = pipeAsyncFunctions

test/pipeAsyncFunctions/pipeAsyncFunctions.test.js

@@ -0,0 +1,24 @@
+const test = require('tape');
+const pipeAsyncFunctions = require('./pipeAsyncFunctions.js');
+
+test('Testing pipeAsyncFunctions', async (t) => {
+  //For more information on all the methods supported by tape
+  //Please go to https://github.com/substack/tape
+  t.true(typeof pipeAsyncFunctions === 'function', 'pipeAsyncFunctions is a Function');
+  //t.deepEqual(pipeAsyncFunctions(args..), 'Expected');
+  //t.equal(pipeAsyncFunctions(args..), 'Expected');
+  //t.false(pipeAsyncFunctions(args..), 'Expected');
+  //t.throws(pipeAsyncFunctions(args..), 'Expected');
+  t.equal(
+    await pipeAsyncFunctions(
+      (x) => x + 1,
+      (x) => new Promise((resolve) => setTimeout(() => resolve(x + 2), 0)),
+      (x) => x + 3,
+      async (x) => await x + 4,
+    )
+    (5),
+    15,
+    'pipeAsyncFunctions result should be 15'
+  );
+  t.end();
+});