format

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: cmdcolin

src/bgzfBlockScan.ts

@@ -20,8 +20,8 @@ export function scanBgzfBlocks(
 
   while (offset + BGZF_MIN_BLOCK_SIZE <= input.length) {
     if (
-      input[offset] !== 0x1F ||
-      input[offset + 1] !== 0x8B ||
+      input[offset] !== 0x1f ||
+      input[offset + 1] !== 0x8b ||
       input[offset + 2] !== 8 ||
       input[offset + 3] !== 4
     ) {
@@ -36,8 +36,7 @@ export function scanBgzfBlocks(
       break
     }
 
-    const bsize =
-      (input[offset + 16]! | (input[offset + 17]! << 8)) + 1
+    const bsize = (input[offset + 16]! | (input[offset + 17]! << 8)) + 1
 
     if (bsize < BGZF_MIN_BLOCK_SIZE || offset + bsize > input.length) {
       break

src/unzip.ts

@@ -1,9 +1,6 @@
 import { ungzip } from 'pako-esm2'
 
-import {
-  type BgzfBlockInfo,
-  scanBgzfBlocks,
-} from './bgzfBlockScan.ts'
+import { type BgzfBlockInfo, scanBgzfBlocks } from './bgzfBlockScan.ts'
 import { concatUint8Array } from './util.ts'
 import {
   decompressAll,
@@ -34,7 +31,7 @@ interface Chunk {
 }
 
 function hasGzipHeader(data: Uint8Array) {
-  return data.length >= 2 && data[0] === 0x1F && data[1] === 0x8B
+  return data.length >= 2 && data[0] === 0x1f && data[1] === 0x8b
 }
 
 async function decompressGzip(inputData: Uint8Array) {
@@ -152,7 +149,10 @@ export async function unzipChunkSlice(
 
     if (blocks.length > 1) {
       let sharedBuf: SharedArrayBuffer
-      if (inputData.buffer instanceof SharedArrayBuffer && inputData.byteOffset === 0) {
+      if (
+        inputData.buffer instanceof SharedArrayBuffer &&
+        inputData.byteOffset === 0
+      ) {
         sharedBuf = inputData.buffer
       } else {
         sharedBuf = new SharedArrayBuffer(inputData.byteLength)
@@ -164,7 +164,12 @@ export async function unzipChunkSlice(
         blocks,
       )
       return {
-        ...assembleChunkSliceResult(decompressResult.blocks, blocks, minv, maxv),
+        ...assembleChunkSliceResult(
+          decompressResult.blocks,
+          blocks,
+          minv,
+          maxv,
+        ),
         timing: decompressResult.timing,
       }
     }

src/workerPool.ts

@@ -26,7 +26,13 @@ export interface WorkerTiming {
 
 type WorkerMessage =
   | { type: 'ready' }
-  | { type: 'rangeResult'; batchId: number; data: Uint8Array; viewMs: number; wasmMs: number }
+  | {
+      type: 'rangeResult'
+      batchId: number
+      data: Uint8Array
+      viewMs: number
+      wasmMs: number
+    }
   | { type: 'error'; message?: string }
 
 interface RangeResult {
@@ -52,10 +58,10 @@ class ManagedWorker {
 
   constructor(workerUrl: string | URL) {
     this.worker = new Worker(workerUrl)
-    this.readyPromise = new Promise<void>((resolve) => {
+    this.readyPromise = new Promise<void>(resolve => {
       this.readyResolve = resolve
     })
-    this.worker.onmessage = (e) => {
+    this.worker.onmessage = e => {
       this.handleMessage(e.data)
     }
   }
@@ -138,7 +144,7 @@ export function getSharedWorkerPool(
   }
   if (!sharedPoolPromise) {
     const gen = poolGeneration
-    sharedPoolPromise = createBgzfWorkerPool(numWorkers).then((pool) => {
+    sharedPoolPromise = createBgzfWorkerPool(numWorkers).then(pool => {
       if (gen !== poolGeneration) {
         pool.destroy()
         throw new Error('Worker pool was destroyed during initialization')
@@ -168,9 +174,7 @@ export async function createBgzfWorkerPool(
   }
 
   const url = workerUrl ?? getWorkerBlobUrl()
-  const count =
-    numWorkers ??
-    Math.min(navigator.hardwareConcurrency, 4)
+  const count = numWorkers ?? Math.min(navigator.hardwareConcurrency, 4)
   const workers: ManagedWorker[] = []
 
   for (let i = 0; i < count; i++) {
@@ -180,7 +184,7 @@ export async function createBgzfWorkerPool(
   for (const w of workers) {
     w.init()
   }
-  await Promise.all(workers.map((w) => w.readyPromise))
+  await Promise.all(workers.map(w => w.readyPromise))
 
   let destroyed = false
 

src/workerPoolClient.ts

@@ -17,7 +17,7 @@ export class BgzfWorkerPoolClient implements BgzfWorkerPool {
 
   constructor(port: MessagePort) {
     this.port = port
-    this.port.onmessage = (e) => {
+    this.port.onmessage = e => {
       this.handleResponse(e.data)
     }
     this.port.start()

src/workerPoolHost.ts

@@ -18,7 +18,7 @@ export class BgzfWorkerPoolHost {
 
   connectPort(port: MessagePort) {
     this.ports.add(port)
-    port.onmessage = (e) => {
+    port.onmessage = e => {
       void this.handleRequest(port, e.data)
     }
     port.start()