Repository Index

Distributed, Scalable, Fault-Tolerant, Minimalistic Workflow Engine - No DAGs, No YAML, No Cumbersome Diagrams, Just Code

• business-process
• kafka
• kafka-streams
• micorservices

Composable Concurrency Abstractions for JavaScript. :railway_track: :rhinoceros: :train: :vertical_traffic_light:

• concurrency
• async-await
• reactive-programming
• streams

Deno KV file system, compatible with Deno deploy. Saves files in 64kb chunks. You can organize files into directories. You can control the KB/s rate for saving and reading files, rate limit, user space limit and limit concurrent operations, useful for controlling uploads/downloads. Makes use of Web Streams API.

• deno
• filesystem

A common lisp logging library providing context sensitive logging of more than just strings to more than just local files / output streams

A streams2 Readable stream generator, useful for testing.

Typed, zero-dependency CSV parser and encoder for TypeScript. Streams with flat memory and runs on Node, browsers, Deno, Bun, and edge.

• bun
• csv
• csv-parser
• deno

library and CLI tool that merges multiple Test Anything Protocol streams

• tap
• stream
• merge

A production-grade messaging abstraction for Go. It provides a unified API to decouple business logic from various brokers including Kafka, RabbitMQ, RocketMQ, NATS, Redis, and AWS SQS. Featuring built-in OpenTelemetry integration and engineered for high reliability.

• go
• kafka
• message-broker
• opentelemetry

Convert node.js Streams into Promises

Streams OSM data in XML format to GeoJSON.

A Deterministic Random Bit Generator based on AES in Counter mode (AES-CTR-DRBG) as specified in NIST SP 800-90A written in Go.

• aes-ctr
• crypto
• drbg
• cipher-algorithms

Ember Cerebral

• cerebral
• cerebraljs
• ember-addon
• immutable

Support for Sound Transit realtime data streams.

Android LiveData inspired .NET implementation - lifecycle aware rx streams

A nice little wrapper around java.util.zip.* using streams