test · moroutine · Tangled

divy.zone / moroutine

Offload functions to worker threads with shared memory primitives for Node.js.

3 folders · 25 files

Devin Ivy · fix(serve): replace /dev/fd dup with readStop+detach for Linux compat · 4mo ago

chore: review cleanups, backpressure tests, changeset

fix(serve): replace /dev/fd dup with readStop+detach for Linux compat

feat(shared): add RwLock.tryWriteLock synchronous variant

abort-signal.test.ts

feat: auto-detect and transfer AbortSignal arguments to workers

fix: move mo() call out of assign test into fixture

async-dispose.test.ts

refactor: use setTimeout from node:timers/promises

balancers.test.ts

feat: roundRobin() and leastBusy() balancer factories

channel-autodetect.test.ts

chore: add prettier, changesets, and Spindle CI workflows

channel-fanout.test.ts

fix(test): eliminate race in shutdown tests

channel-wrapper.test.ts

chore: add prettier, changesets, and Spindle CI workflows

context.test.ts

test: rewrite nested task-arg test to actually test nesting

dedicated.test.ts

feat: dedicated worker runner with integration tests

feat: surface main-thread call site in error stack traces

feat: add examples and freeze module registry on first task dispatch

is-task.test.ts

feat: add isTask() type guard for narrowing tasks to a moroutine

load-balancing.test.ts

chore: prettier lint fixes across project

feat: add inert() and map() helpers for bounded fan-out

feat: registry, Task, and mo() with unit tests

pool-ref.test.ts

fix(test): resolve flaky tests and spike hang

feat: Runner accepts array of tasks, update examples to use run([...])

stream-context.test.ts

fix: remove --test-force-exit, fix test hangs and unhandled rejections

stream-exit.test.ts

chore: add prettier, changesets, and Spindle CI workflows

stream-input.test.ts

chore: review cleanups, backpressure tests, changeset

stream-pipeline.test.ts

fix: remove --test-force-exit, fix test hangs and unhandled rejections

stream-task.test.ts

refactor!: unify Task and StreamTask under Task<T>

chore: review cleanups, backpressure tests, changeset

transfer.test.ts

refactor: rename pool() to workers()

worker-handle.test.ts

chore: formatting fixes