Class GeometryWorkerPool

constructor

• new GeometryWorkerPool(
      size: number,
      createWorker: () => GeometryWorkerLike,
  ): GeometryWorkerPool

  Parameters

  • size: number
  • createWorker: () => GeometryWorkerLike

  Returns GeometryWorkerPool

Readonlysize

buildAll

• buildAll(
      requests: GeometryBuildRequest[],
  ): Promise<(null | GeometryBuildResponse)[]>

  Build every request and return responses in input order. Convenience over buildStreaming for callers that want the whole batch (holds all responses — not memory-bounded; the renderer uses the streaming form). A null slot means the build was skipped (disposed mid-run).

  Parameters

  • requests: GeometryBuildRequest[]

  Returns Promise<(null | GeometryBuildResponse)[]>

buildStreaming

• buildStreaming(
      requests: GeometryBuildRequest[],
      onResult: (index: number, response: GeometryBuildResponse) => void,
  ): Promise<void>

  Stream builds across the pool with backpressure (at most size in flight — each worker pulls the next index only when its previous chunk returns), invoking onResult(index, response) as each completes. Memory-friendly: the caller uploads + drops each response immediately, so peak transient geometry is bounded by size (not the whole batch). Rejects on the first worker error; resolves when every request has been delivered (or the pool was disposed mid-run).

  Parameters

  • requests: GeometryBuildRequest[]
  • onResult: (index: number, response: GeometryBuildResponse) => void

  Returns Promise<void>

dispose

• dispose(): void

  Returns void