A general-purpose abstract component tree built on Effection structured concurrency
Provides Deno Deploy Effection context with `region`, `deploymentId` and `isDenoDeploy` flag to detect when running in the Deno Deploy environment. This can be useful when testing an application that's deployed to Deno Deploy.
A collection of utility functions to streamline asynchronous workflows. These functions were originally part of the [starfx](https://github.com/neurosnap/starfx) project and have been adapted for use with the Effection framework.
Provides Deno Deploy Effection context with `region`, `deploymentId` and `isDenoDeploy` flag to detect when running in the Deno Deploy environment. This can be useful when testing an application that's deployed to Deno Deploy.
Easily offload compute intensive computations to another thread or manage external external processes using Web Workers. A library for seamlessly integrating [Web Workers][Web Workers] with Effection programs.
Run local LDAP server with specific users for local development and integration testing
Watch is a very simple tool that does one thing: run a command, and every time source files change in a directory, shutdown the current invocation _gracefully_ and restart it.
Base simulator to build simulators for integration testing.
State machine runtime for EffectStream
Manages concurrent task execution by enforcing a maximum limit on simultaneously active operations. When this limit is reached, the `TaskBuffer` automatically queues additional spawn requests and processes them in order as capacity becomes available. This
Structured concurrency and effects for JavaScript
Control Webdriver instances
Spawn and manage child processes with structured concurrency
Constrain any operation to complete within a certain time.
Shared utilities for the EffectStream framework
Utility functions for async workflows adapted from starfx
Agent for connecting test environments (browsers) to BigTest
Run commands and restart them gracefully when source files change
Type-safe stream operators like filter, map, reduce, and forEach
Multi-agent inference inside the decode loop — structured concurrency over shared KV state
JSONL Streaming Store provides an easy way to store documents in JSONL files. This is useful when you need cache responses from HTTP requests for later processing. This API focuses on providing streaming APIs for working with the contents of the store wit
WebSocket client with stream-based message handling and automatic cleanup
Lightweight process execution wrapper around tinyexec
Evaluate operations in a scope while retaining resources across evaluations