From 06f0fe6df1586aff5995f043a380b1d47077f9e8 Mon Sep 17 00:00:00 2001
From: Richard <115594235+richardzen@users.noreply.github.com>
Date: Fri, 20 Dec 2024 22:27:04 +0530
Subject: [PATCH] chore: format `concurreny.ts` in maxun-core

---
 maxun-core/src/utils/concurrency.ts | 48 ++++++++++++++---------------
 1 file changed, 24 insertions(+), 24 deletions(-)

diff --git a/maxun-core/src/utils/concurrency.ts b/maxun-core/src/utils/concurrency.ts
index e1ebb87b..56c15fd9 100644
--- a/maxun-core/src/utils/concurrency.ts
+++ b/maxun-core/src/utils/concurrency.ts
@@ -3,36 +3,36 @@
  */
 export default class Concurrency {
   /**
-     * Maximum number of workers running in parallel. If set to `null`, there is no limit.
-     */
+  * Maximum number of workers running in parallel. If set to `null`, there is no limit.
+  */
   maxConcurrency: number = 1;
 
   /**
-     * Number of currently active workers.
-     */
+  * Number of currently active workers.
+  */
   activeWorkers: number = 0;
 
   /**
-     * Queue of jobs waiting to be completed.
-     */
+  * Queue of jobs waiting to be completed.
+  */
   private jobQueue: Function[] = [];
 
   /**
-     * "Resolve" callbacks of the waitForCompletion() promises.
-     */
+  * "Resolve" callbacks of the waitForCompletion() promises.
+  */
   private waiting: Function[] = [];
 
   /**
-     * Constructs a new instance of concurrency manager.
-     * @param {number} maxConcurrency Maximum number of workers running in parallel.
-     */
+  * Constructs a new instance of concurrency manager.
+  * @param {number} maxConcurrency Maximum number of workers running in parallel.
+  */
   constructor(maxConcurrency: number) {
     this.maxConcurrency = maxConcurrency;
   }
 
   /**
-     * Takes a waiting job out of the queue and runs it.
-     */
+  * Takes a waiting job out of the queue and runs it.
+  */
   private runNextJob(): void {
     const job = this.jobQueue.pop();
 
@@ -53,12 +53,12 @@ export default class Concurrency {
   }
 
   /**
-     * Pass a job (a time-demanding async function) to the concurrency manager. \
-     * The time of the job's execution depends on the concurrency manager itself
-     * (given a generous enough `maxConcurrency` value, it might be immediate,
-     * but this is not guaranteed).
-     * @param worker Async function to be executed (job to be processed).
-     */
+  * Pass a job (a time-demanding async function) to the concurrency manager. \
+  * The time of the job's execution depends on the concurrency manager itself
+  * (given a generous enough `maxConcurrency` value, it might be immediate,
+  * but this is not guaranteed).
+  * @param worker Async function to be executed (job to be processed).
+  */
   addJob(job: () => Promise<any>): void {
     // console.debug("Adding a worker!");
     this.jobQueue.push(job);
@@ -72,11 +72,11 @@ export default class Concurrency {
   }
 
   /**
-     * Waits until there is no running nor waiting job. \
-     * If the concurrency manager is idle at the time of calling this function,
-     * it waits until at least one job is completed (can be "presubscribed").
-     * @returns Promise, resolved after there is no running/waiting worker.
-     */
+  * Waits until there is no running nor waiting job. \
+  * If the concurrency manager is idle at the time of calling this function,
+  * it waits until at least one job is completed (can be "presubscribed").
+  * @returns Promise, resolved after there is no running/waiting worker.
+  */
   waitForCompletion(): Promise<void> {
     return new Promise((res) => {
       this.waiting.push(res);