Repository Index

Asynchronous, Reactive Programming for Scala and Scala.js.

• scala
• monix
• typelevel
• functional-programming

Tiny wrapper around Node streams2 Transform to avoid explicit subclassing noise

Probabilistic data structures for processing continuous, unbounded streams.

• bloom-filter
• go
• stable-bloom-filters
• cuckoo-filter

Python Streaming DataFrames for Kafka

• kafka
• python
• stream-processing
• data-engineering

The Scala HTTP client you always wanted!

• scala
• http
• httpclient
• interpolator

An advanced, but easy to use, platform for writing functional applications in Java 8.

• functional-programming
• reactive-streams
• monoid
• streams

tools for working with streams of data

HiveMQ MQTT Client is an MQTT 5.0 and MQTT 3.1.1 compatible and feature-rich high-performance Java client library with different API flavours and backpressure support

• mqtt
• mqtt-client
• mqtt-protocol
• reactive-streams

Node-core streams for userland

• nodejs
• node

A networking framework that evolves with your application

• java
• reactive
• reactive-streams
• microservices

zerocode-tdd is a community-developed, free, open-source, outcome-driven automated testing framework for Data Pipelines, ETL, REST API, Kafka(Data Streams), Databases and Load scenarios. all defined in simple JSON or YAML — with zero coding.

• soap
• assertions
• java
• api

A RocksDB compliant high performance scalable embedded key-value store

• key-value-store
• kvs
• storage-engine
• speedb

pipe streams together and close all of them if one of them closes

An advanced Node.js driver for RethinkDB with a connection pool, support for streams etc.

A functional effect and streaming system for Clojure/Script

• clojure
• clojurescript
• reactive-streams

Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.

• iot
• analytics
• edge
• stream-processing

FFmpeg filter for applying GLSL transitions between video streams.

• ffmpeg
• glsl
• opengl
• transitions

🏎️ Streams & Reactive Programming paradigm for Go: declarative and composable API for event-driven applications

• event-driven
• generics
• go
• golang

Basic Real-time AV Editor - allowing you to preview, mix, and route live audio and video streams on the cloud

• gstreamer
• python
• multimedia
• rtmp

Parallel Collectors is a toolkit easing parallel collection processing in Java using Stream API.

• parallelism
• parallel-streams
• stream-api
• hacktoberfest

Microservices library - scalecube-services is a high throughput, low latency reactive microservices library built to scale. It features: API-Gateways, service-discovery, service-load-balancing, the architecture supports plug-and-play service communication modules and features. built to provide performance and low-latency real-time stream-processing

• microservices
• reactive-streams
• distributed-systems
• service-mesh

A non-backtracking NFA/DFA-based Perl-compatible regex engine matching on large data streams

Local gateway for Claude Code, Codex and other AI clients on macOS, Windows and Linux: switch upstreams without touching clients, keep API keys from relays, cut off malicious tool calls, trace every request.

• ai-gateway
• anthropic
• claude-code
• codex

Conduit streams data between data stores. Kafka Connect replacement. No JVM required.

• go
• data-integration
• etl
• data-pipeline