Awesome GitHub RepositoriesEffect-to-Stream Conversion

node-fetch est une bibliothèque cliente HTTP légère qui implémente l'API Fetch standard des navigateurs pour Node.js. Elle fournit une interface basée sur les promesses pour effectuer des requêtes réseau asynchrones afin de récupérer ou d'envoyer des données depuis des environnements côté serveur. Le projet se spécialise dans la gestion efficace de la mémoire en utilisant le streaming de requêtes et de réponses. Cela permet le traitement incrémental de charges utiles réseau importantes via des flux système natifs pour éviter l'épuisement de la mémoire. La bibliothèque couvre un large éventail de capacités réseau, incluant l'utilisation d'agents HTTP personnalisés pour la configuration DNS et SSL, l'annulation de requêtes via des signaux d'abandon (abort signals), et la gestion de divers encodages de contenu et soumissions de formulaires.

Fluent Bit est un collecteur de logs et de télémétrie unifié cloud-native conçu comme un pipeline de données efficace en ressources. Il ingère des logs, des métriques et des traces provenant de multiples sources, les traitant en temps réel avant d'acheminer les données vers des backends de stockage externes. Le projet fonctionne comme un processeur de flux en temps réel et un processeur de logs OpenTelemetry, capable de transformer et de filtrer les données en utilisant SQL et une logique conditionnelle. Il agit également comme un agent de traçage distribué capable d'échantillonner les traces pour réduire le volume de données tout en préservant les chemins de requête complets. Le système fournit une livraison de données fiable grâce à une mise en mémoire tampon basée sur le système de fichiers et une logique de réessai avec état pour éviter la perte de données lors des pannes. Son architecture modulaire prend en charge des plugins d'entrée et de sortie enfichables, un routage basé sur les métadonnées et la capacité d'étendre les fonctionnalités via des bibliothèques partagées. Le logiciel peut être déployé en tant que conteneur sur différentes architectures CPU et systèmes d'exploitation.

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

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

go-flutter is a runtime and embedding library that enables Flutter applications to run natively on Windows, macOS, and Linux using Go and GLFW. It implements the Flutter Embedding API to render Flutter UIs on desktop platforms, providing a cross-platform desktop runtime that bridges Go and Dart code through standard Flutter method and event channels. The project includes a plugin framework that supports bidirectional communication between Go and Dart, allowing Go code to invoke Dart handlers and expose Go methods for Dart to call, with optional synchronous replies. It also provides event stre

KurrentDB is an event-native database designed for event sourcing and event-driven architectures. It stores events as immutable, ordered records in streams, preserving a complete audit trail and enabling temporal queries. The database uses gRPC for all client-server and inter-node communication, providing efficient binary serialization and bidirectional streaming, and supports atomic multi-stream writes that ensure consistency across multiple streams in a single transaction. The database distinguishes itself with a built-in JavaScript projection engine that transforms, filters, and aggregates

R3 is a reactive extensions library and asynchronous data pipeline framework. It provides a system for composing asynchronous data streams, managing reactive state, and coordinating event sequences using observable patterns. The project distinguishes itself with a deterministic testing toolkit that mocks time and frame updates to ensure reproducible unit tests for asynchronous logic. It also includes observability tools for tracking active subscriptions and generating stack traces to identify memory leaks, alongside centralized exception routing for pipeline recovery. The framework covers a