Awesome GitHub RepositoriesStream Combinators

The Reactive Extensions for JavaScript

This project is a collection of educational resources and reference implementations for the Apache Flink stream processing framework. It provides a learning resource focused on mastering distributed stream processing through implementation guides, performance tuning tutorials, and practical examples. The repository features detailed walkthroughs for building real-time data pipelines using the DataStream and Table APIs. It includes specific integration examples for connecting Apache Flink with Kafka brokers and Elasticsearch indices, as well as reference implementations for real-time deduplica

This project is a sample library and implementation guide for using RxJava to manage asynchronous data streams and concurrent tasks in Android applications. It provides a collection of reference implementations for reactive programming, focusing on functional operators to transform and combine asynchronous data flows. The library demonstrates specific Android architectural patterns, such as implementing decoupled event buses for component communication and coordinating parallel network requests. It includes concrete examples of mobile-specific patterns including search input debouncing, list

python-binance is a Python client library that provides programmatic access to the Binance cryptocurrency exchange through both REST and WebSocket APIs. It serves as a comprehensive toolkit for automated trading, account management, and market data retrieval, enabling developers to build trading bots, portfolio management tools, and data analysis applications that interact directly with the exchange. The library distinguishes itself through a dual-client architecture that separates synchronous REST calls from persistent WebSocket streams, allowing concurrent execution without blocking. It inc

language-ext is a functional programming framework for C# that provides a suite of immutable data structures and monadic types. It enables the implementation of pure functional programming patterns, utilizing containers to manage side effects, optional values, and error handling. The library is distinguished by its advanced concurrency and state management tools, including a software transactional memory system and lock-free atomic references. It also provides specialized utilities for distributed systems, such as vector clocks for causality tracking and deterministic data conflict resolution

Bacon.js is a JavaScript functional reactive programming library used for coordinating complex asynchronous data flows. It functions as an observable event stream framework and an asynchronous data flow orchestrator, allowing developers to model events as declarative streams and properties. The library distinguishes itself through its ability to manage reactive state and synchronize timing across multiple sources. It provides specialized mechanisms for atomic state synchronization to prevent glitches in derived properties and offers advanced coordination strategies such as asynchronous stream

Zero-cost asynchronous programming in Rust

Octosql is a federated SQL query engine, data transformer, and streaming SQL processor. It allows users to execute single SQL statements across multiple disparate data sources, including different database types and file formats, to merge and transform results into a unified set. The system distinguishes itself by treating CSV, JSONLines, and Parquet files as virtual tables and utilizing a plugin-based architecture to extend connectivity to external storage engines. It functions as a streaming processor for infinite data streams, using watermarks, retractions, and tumbling windows to maintain

RxPY is a functional reactive programming library and a ReactiveX observable library for Python. It serves as an asynchronous stream processor and event-driven coordination framework used to build data pipelines that react to changes in state or streams of events over time. The library provides a toolkit for composing asynchronous and event-based programs using observable sequences and operators. It distinguishes itself through the use of configurable schedulers to manage concurrency, timing, and subscription lifecycles. The project covers a wide range of stream processing capabilities, incl

Arroyo is a high-performance stream processing platform built in Rust. It executes continuous SQL queries on streaming data with event-time semantics, enabling accurate windowed aggregations, joins, and stateful computations on unbounded event streams. The platform uses native Rust execution for high throughput and low latency, with periodic checkpointing for exactly-once fault tolerance and horizontal scaling across distributed workers. The system integrates deeply with Kafka for reading and writing topics with exactly-once delivery and supports change data capture (CDC) from MySQL and Postg

ZIO is a functional effect system for the JVM that models asynchronous and concurrent programs as pure, composable values with typed error handling and dependency injection. Its core identity is built on fiber-based concurrency, where lightweight, non-blocking fibers execute millions of concurrent tasks with structured lifecycle management, and a dual-channel error model that separates expected business failures from unexpected system defects at compile time. The system provides effect-typed dependency injection through a layer-based dependency graph, pull-based reactive stream processing with

more-itertools एक Python इटरेबल यूटिलिटी लाइब्रेरी है जो डेटा सीक्वेंस को मैनिपुलेट, फिल्टर और ट्रांसफॉर्म करने के लिए एडवांस्ड फंक्शन्स प्रदान करती है। यह डेटा स्ट्रीम प्रोसेसिंग टूलकिट और इटरेशन स्टेट मैनेजमेंट के लिए यूटिलिटीज का एक सेट है, जो स्टैंडर्ड Python itertools मॉड्यूल की क्षमताओं का विस्तार करता है। इस लाइब्रेरी में परम्यूटेशन, कॉम्बिनेशन और पावरसेट्स जनरेट करने के लिए एक कॉम्बिनेटरियल मैथ टूलकिट शामिल है, साथ ही नंबर थ्योरी कैलकुलेशन और मैट्रिक्स ऑपरेशंस के लिए रूटीन भी हैं। यह स्ट्रीम स्टेट मैनेजमेंट के लिए टूल्स भी प्रदान करती है, जिससे यूजर्स आने वाले एलिमेंट्स को देख सकते हैं या डेटा को कैसे कंज्यूम किया जाए, इसे नियंत्रित करने के लिए सीक्वेंस के भीतर सर्च कर सकते हैं। अतिरिक्त क्षमताओं में जटिल सीक्वेंस को चंकिंग, इंटरलीविंग और फ्लैटनिंग करने के लिए डेटा प्रोसेसिंग रूटीन शामिल हैं। इस टूलकिट में इटरेबल प्रॉपर्टीज का विश्लेषण करने और समवर्ती डेटा स्ट्रीम्स को सिंक्रोनाइज़ करने के लिए फंक्शन्स भी शामिल हैं।

MoreLINQ is a functional programming toolkit and extension library for .NET that augments LINQ to Objects with advanced operators for sequence manipulation and analysis. It provides a set of tools for declarative data transformation, leveraging lazy evaluation and composition to handle complex object sequences. The library is distinguished by its specialized capabilities for combinatorial generation, including the production of permutations, subsets, and Cartesian products. It also provides advanced sequence joining options, such as full, left, and right outer joins, and supports complex data