Async Reduce

- Removed unused `newlyAddedElements` logic
- Updated TypeScript definition files

Author: Sykander

src/async-filter.js

@@ -20,8 +20,7 @@ async function asyncFilter(iterable, callback, thisArg = undefined) {
 		iterable,
 		await Promise.all(
 			mapIterable(iterable, callback.bind(thisArg), {
-				useEmptyElements: false,
-				newlyAddedElements: false
+				useEmptyElements: false
 			})
 		)
 	);

src/async-find-index.js

@@ -17,8 +17,7 @@ async function asyncFindIndex(iterable, callback, thisArg = undefined) {
 	validateIsFunction(callback);
 
 	const tasks = mapIterable(iterable, callback.bind(thisArg), {
-		useEmptyElements: true,
-		newlyAddedElements: false
+		useEmptyElements: true
 	});
 
 	return Promise.race([

src/async-find.js

@@ -17,8 +17,7 @@ async function asyncFind(iterable, callback, thisArg = undefined) {
 	validateIsFunction(callback);
 
 	const tasks = mapIterable(iterable, callback.bind(thisArg), {
-		useEmptyElements: true,
-		newlyAddedElements: false
+		useEmptyElements: true
 	});
 
 	return iterable[

src/async-for-each.js

@@ -17,8 +17,7 @@ async function asyncForEach(iterable, callback, thisArg = undefined) {
 
 	await Promise.all(
 		mapIterable(iterable, callback.bind(thisArg), {
-			useEmptyElements: false,
-			newlyAddedElements: false
+			useEmptyElements: false
 		})
 	);
 }

src/async-map.js

@@ -18,8 +18,7 @@ async function asyncMap(iterable, callback, thisArg = undefined) {
 
 	return Promise.all(
 		mapIterable(iterable, callback.bind(thisArg), {
-			useEmptyElements: false,
-			newlyAddedElements: false
+			useEmptyElements: false
 		})
 	);
 }

types/async-array.d.ts

@@ -2,7 +2,7 @@
  * Async Array
  * ===========
  * Array like object with access to async array methods
- * @class AsyncArray
+ * @class
  * @extends Array
  */
 export class AsyncArray extends Array<any> {

types/async-reduce.d.ts

@@ -6,8 +6,8 @@
  * @async
  * @param {Object} iterable
  * @param {Function} callback - callback(currentValue, index, array)
- * @param {any} [accumulator]
+ * @param {any} [accumulator=noParam]
  * @return {any}
  * @throws {TypeError}
  */
-export function asyncReduce(): any;
+export function asyncReduce(iterable: any, transducer: any, accumulator?: any): any;

types/constants.d.ts

@@ -0,0 +1,5 @@
+/**
+ * @const {Symbol} noParam
+ * For representing when no parameter was passed to a function
+ */
+export const noParam: any;

types/helpers.d.ts

@@ -7,12 +7,10 @@
  * @param {Function} callback
  * @param {Object} [options]
  * @param {Boolean} [options.useEmptyElements=true] - use empty elements of the array ?
- * @param {Boolean} [options.newlyAddedElements=false] - visit newly added elements ?
  * @return {Array}
  */
-export function mapIterable(iterable: any, callback: Function, { useEmptyElements, newlyAddedElements }?: {
+export function mapIterable(iterable: any, callback: Function, { useEmptyElements }?: {
     useEmptyElements: boolean;
-    newlyAddedElements: boolean;
 }): any[];
 /**
  * Filter Iterable

types/validation.d.ts

@@ -1,12 +1,21 @@
 /**
  * Validate an item's iterability
  * @param {any} item
+ * @return {Boolean} validated?
  * @throws {TypeError}
  */
 export function validateIsIterable(item: any): boolean;
 /**
  * Validate an item is a function
  * @param {any} item
+ * @return {Boolean} validated?
  * @throws {TypeError}
  */
 export function validateIsFunction(item: any): boolean;
+/**
+ * Validate if an item has length greater than 0
+ * @param {any} item
+ * @return {Boolean} validated?
+ * @throws {TypeError}
+ */
+export function validateNonZeroLength(item: any): boolean;