Added SyncPromise.all static method

kamilogorek · kamilogorek · commit f459bbada99d · 2019-10-03T10:38:04.000+02:00
diff --git a/packages/utils/src/promisebuffer.ts b/packages/utils/src/promisebuffer.ts
@@ -69,7 +69,7 @@ export class PromiseBuffer<T> {
           resolve(false);
         }
       }, timeout);
-      Promise.all(this._buffer)
+      SyncPromise.all(this._buffer)
         .then(() => {
           clearTimeout(capturedSetTimeout);
           resolve(true);
diff --git a/packages/utils/src/syncpromise.ts b/packages/utils/src/syncpromise.ts
@@ -53,6 +53,39 @@ export class SyncPromise<T> implements Promise<T> {
     });
   }
 
+  /** JSDoc */
+  public static all<U = any>(collection: Array<U | PromiseLike<U>>): Promise<U[]> {
+    return new SyncPromise<U[]>((resolve, reject) => {
+      if (!Array.isArray(collection)) {
+        reject(new TypeError(`Promise.all requires an array as input.`));
+        return;
+      }
+
+      if (collection.length === 0) {
+        resolve([]);
+        return;
+      }
+
+      let counter = collection.length;
+      const resolvedCollection: U[] = [];
+
+      collection.forEach((item, index) => {
+        SyncPromise.resolve(item)
+          .then(value => {
+            resolvedCollection[index] = value;
+            counter -= 1;
+
+            if (counter !== 0) {
+              return;
+            }
+
+            resolve(resolvedCollection);
+          })
+          .catch(reject);
+      });
+    });
+  }
+
   /** JSDoc */
   public then<TResult1 = T, TResult2 = never>(
     onfulfilled?: ((value: T) => TResult1 | PromiseLike<TResult1>) | null,

Original file line number	Diff line number	Diff line change
`@@ -69,7 +69,7 @@ export class PromiseBuffer<T> {`
`69`	`69`	`resolve(false);`
`70`	`70`	`}`
`71`	`71`	`}, timeout);`
`72`		`- Promise.all(this._buffer)`
	`72`	`+ SyncPromise.all(this._buffer)`
`73`	`73`	`.then(() => {`
`74`	`74`	`clearTimeout(capturedSetTimeout);`
`75`	`75`	`resolve(true);`