API Reference skuld_concurrency v#0.47.0

View Source

Modules

Run a computation in a separate process, bridging yields, throws, and results back to the calling process via messages.

Internal suspension for Env-aware code.

Cooperative fiber primitive for the FiberPool scheduler.

Fiber that was cancelled before completion.

Fiber that finished successfully.

Canonical error representation for fiber failures.

Fiber that terminated with an error.

Fiber suspended for an external caller (e.g. Yield).

Fiber state when a single fiber suspends on a foreign resource.

Aggregate of all pending foreign suspensions, returned to the caller (e.g., the Hologram JS runtime) when the FiberPool scheduler exhausts internal work.

Fiber suspended with an internal scheduler dependency (channel, batch, await).

Fiber waiting to be run for the first time.

High-level streaming API built on channels.

Single-writer, multi-reader mutable state for concurrent fibers.

Bounded channel with suspending put/take operations and error propagation.

Effect for cooperative fiber-based concurrency.

Mixed bag of results from await_all!/1 when at least one fiber failed.

Structured error for a single fiber/task failure.

Successful result wrapper used only inside AwaitAllResults.results.

Effect for BEAM Task-based parallelism within a FiberPool.

Main computation driver for the FiberPool.

An always-on process hosting a FiberPool scheduler with bidirectional message passing.

Protocol for resolving ForeignSuspend values across different platforms.

Resolution loop for ForeignSuspend values.

LiveView integration for FiberPool.Server — a multi-fiber page machine with bidirectional message passing.

Typed protocol contract for PageMachine spindle ↔ LiveView communication.

Named concurrent sub-computations (spindles) that run as fibers within a FiberPool. Each spindle is identified by an atom key and communicates results through auto-tagged yields.