Added SyncPromise.all static method

Author: kamilogorek

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);

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,