Anabranch

A TypeScript monorepo for async utilities with first-class error handling. Compatible with Deno, Node.js, and, occasionally, browsers.

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