test · moroutine · Tangled

divy.zone / moroutine

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

3 folders · 30 files

at divy/runtime-v2

Devin Ivy · feat: validate runtime balancer state is thread-safe at boot · 2mo ago

feat: validate runtime balancer state is thread-safe at boot

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

active-counts.test.ts

fix: guard foreign balancer handles, harden ActiveCounts

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

async-dispose.test.ts

refactor: use setTimeout from node:timers/promises

balancers.test.ts

fix: require initialState for stateful balancers, strengthen tests

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!: bare await dispatches to global runtime; remove dedicated workers

fix(test): freeze test isolates define-only module; TODO stream-error note

fix: pin stream-arg runtime dispatch, guard worker-side boot

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

fix: require initialState for stateful balancers, strengthen tests

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

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

pool-ref.test.ts

fix: harden lazy refMode — stream rejection arm, refCount coverage

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

runtime-definition.test.ts

feat: RuntimeDefinition and built-in default runtime definition

runtime-lifecycle.test.ts

feat: validate runtime balancer state is thread-safe at boot

runtime.test.ts

fix: idempotent runtime shutdown, shared TaskResults, guard tests

stream-context.test.ts

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

stream-exit.test.ts

fix: pin stream-arg runtime dispatch, guard worker-side boot

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

fix!: pinning a foreign pool handle throws instead of rebalancing