René's URL Explorer Experiment

Title: Add phase-2 concurrency helpers and an optional fluent pipeline layer by Copilot · Pull Request #83 · bQuery/bQuery · GitHub

Open Graph Title: Add phase-2 concurrency helpers and an optional fluent pipeline layer by Copilot · Pull Request #83 · bQuery/bQuery

X Title: Add phase-2 concurrency helpers and an optional fluent pipeline layer by Copilot · Pull Request #83 · bQuery/bQuery

Description: This moves @bquery/bquery/concurrency closer to the planned threadts-universal parity target without turning bQuery into a 1:1 port. It keeps the low-level worker/task/pool contract stable, adds the next thin collection layer, and introduces Phase 3 as an optional fluent pipeline over the existing primitives. Concurrency surface Added Phase 2 collection helpers: filter() reduce() some() every() find() Added Phase 3 fluent API: pipeline() Design boundaries Keeps the low-level contract unchanged: task workers, RPC workers, pools, lifecycle, queueing, timeout/abort, and error semantics remain the base layer. The new APIs stay explicit, browser-only, tree-shakeable, and serialization-driven. No proxies, decorators, bundler glue, or hidden worker runtime were introduced. Pipeline layer pipeline() is an immutable wrapper over the existing collection helpers. Transform stages return new pipelines; terminal stages delegate to existing helpers: .map() .filter() .toArray() .some() .every() .find() .reduce() Default pipeline options flow into per-stage execution, while stage-local overrides remain possible. Public API / typing Exported the new helpers from: src/concurrency/index.ts src/full.ts Added public pipeline types: ConcurrencyPipeline ConcurrencyPipelineOptions Kept collection helper types aligned with the existing pool-backed model. Docs / parity matrix Updated the concurrency guide parity matrix to make the product boundary explicit: supported low-level primitives adapted collection helpers adapted optional pipelines explicitly not-adopted magic/runtime features Synced README, agent context, and changelog with the expanded concurrency surface and phased roadmap. import { pipeline } from '@bquery/bquery/concurrency'; const results = await pipeline([1, 2, 3, 4], { batchSize: 2, concurrency: 2, }) .map((value) => value * 2) .filter((value) => value > 4) .toArray(); // [6, 8]

Open Graph Description: This moves @bquery/bquery/concurrency closer to the planned threadts-universal parity target without turning bQuery into a 1:1 port. It keeps the low-level worker/task/pool contract stable, adds th...

X Description: This moves @bquery/bquery/concurrency closer to the planned threadts-universal parity target without turning bQuery into a 1:1 port. It keeps the low-level worker/task/pool contract stable, adds th...

Opengraph URL: https://github.com/bQuery/bQuery/pull/83

X: @github

direct link

Domain: github.com

Links:

Viewport: width=device-width