feat(worker): progressive streaming analysis with converging estimates#106

Open

trieloff wants to merge 26 commits intoprereleasefrom

feat/progressive-incremental-worker

Commits on Dec 11, 2025

feat(worker): progressive + streaming ingestion; wrapper API (StreamingDataChunks); demo; docs; exports
soharaa
committed
feat(session): AbortSignal support, optional Worker instance, better error handling; keep API compatible
soharaa
committed
chore(session): silence unknown message-id warnings; propagate worker errors to inflight
soharaa
committed
refactor(api): unify wrapper export at ./worker/streaming; drop session + client shim; update demo/tests/docs accordingly
soharaa
committed
chore(lint): fix Helix ESLint issues in worker + browser tests; keep repo config unchanged; limit lint scope to PR files
soharaa
committed
chore(lint): restore full lint script (eslint .) to surface remaining issues post-merge
soharaa
committed
feat(constants): export PHASE_EPSILON, DEFAULT_BINS, AUTO_ADVANCE_INTERVAL_MS from engine.js and replace inline epsilon usage
soharaa
committed
refactor(constants): import PHASE_EPSILON from engine in progressive.js and remove inline 1e-9
soharaa
committed
refactor(constants): import shared PHASE_EPSILON/DEFAULT_BINS/AUTO_ADVANCE; remove magic numbers; reuse DataChunks; make auto-advance interval configurable; add onError; bound loadedSlices via maxS…
soharaa
committed
docs(types): add Snapshot JSDoc and clarify totals vs sampleTotals/estimates semantics
soharaa
committed
test(worker+wrapper): add cancellation test for progressive worker; add fake-worker browser tests for onError and maxSlices replay bound
soharaa
committed
chore(dev-deps): align ESLint v9 with helix config; bump eslint-plugin-import to 2.32.0; regenerate lock for npm ci
soharaa
committed
test(wrapper): stabilize onError test with wait loop; assert raw result shape
soharaa
committed
chore(tests): satisfy ESLint for new tests (headers, max-len, mixing ops)
soharaa
committed

Commits on Dec 12, 2025

Commits on Dec 13, 2025

ci: run browser tests in GH Actions (web-test-runner + Puppeteer) with COOP/COEP devServer config
soharaa
committed

Commits on Dec 14, 2025

ci(test): add --no-sandbox flags to Puppeteer when CI to ensure Chromium can spawn nested workers
soharaa
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

feat(worker): progressive streaming analysis with converging estimates#106

feat(worker): progressive streaming analysis with converging estimates#106
trieloff wants to merge 26 commits intoprereleasefrom
feat/progressive-incremental-worker

Commits on Dec 11, 2025

feat(worker): progressive + streaming ingestion; wrapper API (StreamingDataChunks); demo; docs; exports

feat(session): AbortSignal support, optional Worker instance, better error handling; keep API compatible

chore(session): silence unknown message-id warnings; propagate worker errors to inflight

refactor(api): unify wrapper export at ./worker/streaming; drop session + client shim; update demo/tests/docs accordingly

chore(lint): fix Helix ESLint issues in worker + browser tests; keep repo config unchanged; limit lint scope to PR files

chore(lint): restore full lint script (eslint .) to surface remaining issues post-merge

feat(constants): export PHASE_EPSILON, DEFAULT_BINS, AUTO_ADVANCE_INTERVAL_MS from engine.js and replace inline epsilon usage

refactor(constants): import PHASE_EPSILON from engine in progressive.js and remove inline 1e-9

refactor(constants): import shared PHASE_EPSILON/DEFAULT_BINS/AUTO_ADVANCE; remove magic numbers; reuse DataChunks; make auto-advance interval configurable; add onError; bound loadedSlices via maxS…

docs(types): add Snapshot JSDoc and clarify totals vs sampleTotals/estimates semantics

test(worker+wrapper): add cancellation test for progressive worker; add fake-worker browser tests for onError and maxSlices replay bound

chore(dev-deps): align ESLint v9 with helix config; bump eslint-plugin-import to 2.32.0; regenerate lock for npm ci

test(wrapper): stabilize onError test with wait loop; assert raw result shape

chore(tests): satisfy ESLint for new tests (headers, max-len, mixing ops)

Commits on Dec 12, 2025

feat(streaming): add mergeable quantile histograms; group commands in worker to merge shards in-worker; wrapper supports shards with in-worker merging and prefers mergeable quantiles

test(parallel): add but temporarily skip due to nested worker limitations

test(parallel): skip execution in web-test-runner environment

docs(demo): enable parallel streaming by default; wrapper auto-selects orchestrator and displays shard count in UI

fix(orchestrator): track per-subworker reqId from stream:init and pass it to stream:add/phase/end to avoid 'no streaming run' errors; resolves demo parallel errors

docs(demo): scale shards to hardwareConcurrency (min 2) for maximum parallelism

fix(demo+wrapper): terminate workers on close; auto-close after done; close previous run on restart to avoid orphaned workers

fix(streaming): guard ensureInit with a single in-flight initPromise to prevent duplicate stream:init and runaway worker spawning; eliminates phantom second run with 0 ingestion

fix(streaming+demo): avoid finalizing a non-existent run; demo cancels pending timers on Done to prevent late finalize from spawning a new run

test(parallel): relax quantile check to presence of quantiles object to avoid flakiness on earliest frames; CI-friendly

Commits on Dec 13, 2025

ci: run browser tests in GH Actions (web-test-runner + Puppeteer) with COOP/COEP devServer config

Commits on Dec 14, 2025

ci(test): add --no-sandbox flags to Puppeteer when CI to ensure Chromium can spawn nested workers

feat(worker): progressive streaming analysis with converging estimates#106trieloff wants to merge 26 commits intoprereleaseadobe/rum-distiller:prereleasefrom feat/progressive-incremental-workeradobe/rum-distiller:feat/progressive-incremental-workerCopy head branch name to clipboard

Commits

Commits on Dec 11, 2025

Commits on Dec 12, 2025

Commits on Dec 13, 2025

Commits on Dec 14, 2025

feat(worker): progressive streaming analysis with converging estimates#106
trieloff wants to merge 26 commits intoprereleasefrom
feat/progressive-incremental-worker