From 9af3e24c25b281fb1e036946ab2fb2c7536287af Mon Sep 17 00:00:00 2001
From: Devin Ivy <devinivy@gmail.com>
Date: Tue, 14 Apr 2026 00:26:43 -0400
Subject: [PATCH] chore: formatting fixes

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
---
 .changeset/async-worker-cleanup.md | 2 +-
 .changeset/per-worker-dispatch.md  | 2 +-
 README.md                          | 4 ++--
 src/execute.ts                     | 4 +++-
 test/fixtures/async-dispose.ts     | 5 ++++-
 test/worker-handle.test.ts         | 5 +----
 6 files changed, 12 insertions(+), 10 deletions(-)

diff --git a/.changeset/async-worker-cleanup.md b/.changeset/async-worker-cleanup.md
index 7e3502a..b659485 100644
--- a/.changeset/async-worker-cleanup.md
+++ b/.changeset/async-worker-cleanup.md
@@ -1,5 +1,5 @@
 ---
-"moroutine": minor
+'moroutine': minor
 ---
 
 Graceful async worker pool shutdown
diff --git a/.changeset/per-worker-dispatch.md b/.changeset/per-worker-dispatch.md
index 63ac136..78d7816 100644
--- a/.changeset/per-worker-dispatch.md
+++ b/.changeset/per-worker-dispatch.md
@@ -1,5 +1,5 @@
 ---
-"moroutine": minor
+'moroutine': minor
 ---
 
 Per-worker dispatch with `assign()` and `run.workers`
diff --git a/README.md b/README.md
index c6887b3..c0d2189 100644
--- a/README.md
+++ b/README.md
@@ -74,8 +74,8 @@ Use `await using` for graceful async shutdown. The pool exposes a `signal` that
 {
   await using run = workers(4);
 
-  run(longTask(run.signal));  // task can react to abort
-  run(otherTask());           // runs to completion
+  run(longTask(run.signal)); // task can react to abort
+  run(otherTask()); // runs to completion
 }
 // signal fired, waited for both tasks, then workers terminated
 ```
diff --git a/src/execute.ts b/src/execute.ts
index 84f7e77..b6df811 100644
--- a/src/execute.ts
+++ b/src/execute.ts
@@ -170,7 +170,9 @@ export function dispatchStream<T>(
   worker.postMessage(msg, [...extracted.transfer, ...ports, port2] as any[]);
 
   let resolveDone: () => void;
-  const donePromise = new Promise<void>((r) => { resolveDone = r; });
+  const donePromise = new Promise<void>((r) => {
+    resolveDone = r;
+  });
 
   const queue: T[] = [];
   let done = false;
diff --git a/test/fixtures/async-dispose.ts b/test/fixtures/async-dispose.ts
index 718b154..545b489 100644
--- a/test/fixtures/async-dispose.ts
+++ b/test/fixtures/async-dispose.ts
@@ -8,7 +8,10 @@ export const slowTask = mo(import.meta, async (ms: number): Promise<string> => {
 
 export const waitForAbort = mo(import.meta, (signal: AbortSignal): Promise<string> => {
   return new Promise((resolve) => {
-    if (signal.aborted) { resolve('aborted'); return; }
+    if (signal.aborted) {
+      resolve('aborted');
+      return;
+    }
     signal.addEventListener('abort', () => resolve('aborted'));
   });
 });
diff --git a/test/worker-handle.test.ts b/test/worker-handle.test.ts
index a41e842..18e02d2 100644
--- a/test/worker-handle.test.ts
+++ b/test/worker-handle.test.ts
@@ -50,10 +50,7 @@ describe('WorkerHandle', () => {
   it('assign() works in a batch', async () => {
     const run = workers(2);
     try {
-      const results = await run([
-        assign(run.workers[0], identity(1)),
-        assign(run.workers[1], identity(2)),
-      ]);
+      const results = await run([assign(run.workers[0], identity(1)), assign(run.workers[1], identity(2))]);
       assert.deepEqual(results, [1, 2]);
     } finally {
       run[Symbol.dispose]();
-- 
2.51.2