Async streams that keep flowing, even when things go wrong
Google Cloud Datastore adapter for @anabranch/nosql
RabbitMQ adapter for @anabranch/queue using amqplib. Supports all queue features with RabbitMQ queues for persistent messaging.
S3 adapter for @anabranch/storage using @aws-sdk/client-s3. Supports presigned URLs, multipart uploads, and all storage operations.
Redis adapter for @anabranch/queue using ioredis. Supports all queue features with Redis streams for persistent messaging.
GCS adapter for @anabranch/storage using @google-cloud/storage. Supports signed URLs and all storage operations.
Crawl websites and find broken links. Uses web-client for robust HTTP and anabranch streams for concurrent processing with backpressure.
Redis adapter for @anabranch/cache using ioredis with native TTL support
PostgreSQL database connector using node:pg with connection pooling, cursor-based streaming, and pub/sub via LISTEN/NOTIFY.
Database abstraction with Task/Stream semantics. In-memory adapter for testing, adapters for PostgreSQL, MySQL, and SQLite.
SQLite database connector using Node.js built-in node:sqlite for in-memory or file-based databases.
Message queue with Task/Stream semantics. In-memory adapter with delayed messages, dead letter queues, and visibility timeout.
Browser storage adapter using IndexedDB. Works in browsers and Web Workers.
MySQL database connector using mysql2 with connection pooling for MySQL databases.
Streaming file-system utilities for reading, walking, globbing, and watching files with composable error handling.
Object storage primitives with Task/Stream semantics. In-memory adapter with generic interface for cloud providers.
Event log with Task/Stream semantics. In-memory adapter for event-sourced systems with cursor-based consumption.
NoSQL document collection primitives with Task/Stream semantics
Kafka adapter for eventlog using kafkajs with Task/Stream semantics
Modern HTTP client built on fetch with automatic retries, timeouts, and rate-limit handling. Returns Task for composable error handling.
Cache primitives with Task semantics for composable error handling