chore: formatting

src/consumer.ts

@@ -357,7 +357,9 @@ export class Consumer extends TypedEventEmitter {
               });
             }
             waitingMessages++;
-            await new Promise((resolve) => setTimeout(resolve, this.concurrencyWaitTimeMs));
+            await new Promise((resolve) =>
+              setTimeout(resolve, this.concurrencyWaitTimeMs),
+            );
             if (this.stopped) return;
           }
           waitingMessages = Math.max(0, waitingMessages - 1);

src/validation.ts

@@ -62,7 +62,9 @@ function validateOption(
       break;
     case "concurrencyWaitTimeMs":
       if (!Number.isInteger(value) || value < 0) {
-        throw new Error("concurrencyWaitTimeMs must be a non-negative integer.");
+        throw new Error(
+          "concurrencyWaitTimeMs must be a non-negative integer.",
+        );
       }
       break;
     default:
@@ -97,7 +99,11 @@ function assertOptions(options: ConsumerOptions): void {
     validateOption("concurrency", options.concurrency, options);
   }
   if (options.concurrencyWaitTimeMs !== undefined) {
-    validateOption("concurrencyWaitTimeMs", options.concurrencyWaitTimeMs, options);
+    validateOption(
+      "concurrencyWaitTimeMs",
+      options.concurrencyWaitTimeMs,
+      options,
+    );
   }
 }
 

test/tests/consumer.test.ts

@@ -2698,7 +2698,7 @@ describe("Consumer", () => {
       sandbox.assert.calledWithMatch(
         optionUpdatedListener,
         "concurrencyWaitTimeMs",
-        100
+        100,
       );
     });