Async stream processing where errors are collected alongside values
instead of stopping the pipeline. Built on Task and Channel
primitives.
Crawl websites and find broken links. Uses web-client for robust HTTP
and anabranch streams for concurrent processing with backpressure.
Database abstraction with Task/Stream semantics. In-memory adapter for
testing, adapters for PostgreSQL, MySQL, and SQLite.
MySQL database connector using mysql2 with connection pooling for
MySQL databases.
PostgreSQL database connector using node:pg with connection pooling
and cursor-based streaming for large result sets.
SQLite database connector using Node.js built-in node:sqlite for
in-memory or file-based databases.
Event log with Task/Stream semantics. In-memory adapter for
event-sourced systems with cursor-based consumption.
Kafka adapter for eventlog using kafkajs with Task/Stream semantics
Streaming file-system utilities for reading, walking, globbing, and
watching files with composable error handling.
Message queue with Task/Stream semantics. In-memory adapter with
delayed messages, dead letter queues, and visibility timeout.
RabbitMQ adapter for @anabranch/queue using amqplib. Supports all
queue features with RabbitMQ queues for persistent messaging.
Redis adapter for @anabranch/queue using ioredis. Supports all queue
features with Redis streams for persistent messaging.
Object storage primitives with Task/Stream semantics. In-memory
adapter with generic interface for cloud providers.
Browser storage adapter using IndexedDB. Works in browsers and Web
Workers.
GCS adapter for @anabranch/storage using @google-cloud/storage.
Supports signed URLs and all storage operations.
S3 adapter for @anabranch/storage using @aws-sdk/client-s3. Supports
presigned URLs, multipart uploads, and all storage operations.
Modern HTTP client built on fetch with automatic retries, timeouts,
and rate-limit handling. Returns Task for composable error handling.