9 dépôts
Chains function calls by piping a value through a sequence of transformations using an overloaded operator.
Distinct from Stream Piping: Distinct from Stream Piping: operates on function composition at the language level, not data streams.
Explore 9 awesome GitHub repositories matching software engineering & architecture · Function Composition Operators. Refine with filters or upvote what's useful.
Haxe is a statically typed, multi-target programming language and open-source compiler toolkit that translates a single codebase into native executables and scripts for JavaScript, C++, C#, Java, Python, Lua, PHP, and Flash targets. It provides a unified type system with automatic type inference, a compile-time macro system for code transformation and generation, conditional compilation directives, and a static analysis engine that enforces null safety and eliminates dead code to produce smaller, safer outputs. The language is supported by the HashLink virtual machine, which executes platform
Provides function piping via an overloaded operator to chain transformations sequentially.
RxGo est une bibliothèque de programmation réactive fonctionnelle et une implémentation de ReactiveX pour le langage Go. Elle sert de boîte à outils de traitement de flux asynchrone conçue pour coordonner les programmes basés sur les événements et les flux de données en utilisant le pattern observable. La bibliothèque permet la construction de pipelines de traitement asynchrones qui transforment, filtrent et combinent des séquences d'événements. Elle se distingue par l'utilisation d'opérateurs fonctionnels pour composer ces pipelines et fournit des mécanismes pour gérer l'exécution concurrente. La boîte à outils couvre un large éventail de capacités d'orchestration de flux, incluant l'agrégation de données, la combinaison de flux multiples et la conversion de flux en structures de données statiques. Elle inclut un support intégré pour la récupération d'erreurs, le contrôle de contre-pression (backpressure) pour réguler les vitesses de production de données, et le pooling de travailleurs pour paralléliser le traitement sur les cœurs CPU.
Links discrete processing functions into sequences where data flows from one operator to the next.
RxPY est une bibliothèque de programmation réactive fonctionnelle et une bibliothèque d'observables ReactiveX pour Python. Elle sert de processeur de flux asynchrone et de framework de coordination piloté par les événements, utilisé pour construire des pipelines de données qui réagissent aux changements d'état ou aux flux d'événements au fil du temps. La bibliothèque fournit une boîte à outils pour composer des programmes asynchrones et basés sur les événements en utilisant des séquences observables et des opérateurs. Elle se distingue par l'utilisation de planificateurs configurables pour gérer la concurrence, le timing et les cycles de vie des abonnements. Le projet couvre un large éventail de capacités de traitement de flux, y compris l'agrégation, le filtrage et la combinaison de données. Il fournit des mécanismes pour la diffusion d'événements, la mise en tampon de séquences et la gestion des erreurs, ainsi que des outils pour coordonner les flux observables avec des boucles d'événements asynchrones. Les tests et l'assurance qualité sont pris en charge par la simulation de temps virtuel, la modélisation par diagrammes de billes et la vérification des émissions.
Enables declarative pipeline composition where the output of one stream operator becomes the input of the next.
Ce dépôt est une collection de modèles d'implémentation pratiques et d'exemples de référence pour utiliser RxJava 2 afin de gérer des flux de données asynchrones dans les applications Android. Il sert de guide d'implémentation de programmation réactive, fournissant des exemples de code pour gérer une logique complexe pilotée par les événements et des modèles asynchrones dans des environnements mobiles. Le projet se distingue en fournissant des implémentations de référence spécifiques pour les défis mobiles courants, tels que la recherche en temps réel avec debouncing, la pagination de liste à la demande pour le défilement infini, et le streaming de données avec priorité au cache pour réduire les temps de chargement perçus. Il inclut également des exemples d'architectures de bus d'événements pour une communication applicative découplée. La base de code couvre un large éventail de capacités réactives, y compris la gestion du cycle de vie des abonnements pour éviter les fuites de mémoire, le changement de thread via des schedulers, et l'utilisation d'opérateurs fonctionnels pour la transformation et la combinaison de flux de données. Il démontre en outre la coordination réseau asynchrone et l'utilisation de composite disposables pour la gestion des abonnements de groupe.
Uses functional operators in chains to filter, map, and combine asynchronous data emissions.
Scriban est une bibliothèque de templating de texte et un moteur de scripting .NET utilisé pour la génération de texte dynamique. Il fonctionne comme un processeur de template et un bac à sable de scripting sécurisé, fournissant un environnement d'exécution sécurisé qui restreint l'exposition des objets pour empêcher l'exécution de code non autorisé. Le projet inclut également un analyseur de template d'arbre syntaxique abstrait qui permet l'analyse et la modification programmatique des templates. Le moteur dispose d'un moteur de template Liquid dédié et d'un mode de compatibilité, lui permettant d'analyser, d'exécuter et de convertir des templates écrits en syntaxe Liquid. Il se distingue par un système de filtrage d'exposition des membres qui permet aux développeurs de renommer, masquer ou filtrer les propriétés d'objets pour contrôler la manière dont les données sont accédées au sein des templates. La bibliothèque couvre un large éventail de capacités incluant le rendu de template asynchrone, la logique conditionnelle et l'itération de collection. Elle fournit des utilitaires intégrés pour la manipulation de données, tels que des opérations mathématiques, la conversion JSON, l'arithmétique de date et d'heure, et un traitement de texte étendu utilisant des expressions régulières. Les développeurs peuvent en outre étendre le moteur en définissant des fonctions personnalisées et en intégrant des classes externes. Le projet fournit une surface API sécurisée pour prendre en charge la publication en tant que binaire natif via Native AOT.
Manipulates template values using built-in operations chained through a pipe operator.
RxDocs is a community-driven project that provides comprehensive technical documentation and educational resources for reactive programming. It serves as a centralized reference for developers implementing asynchronous data streams, offering detailed guides and operator specifications to support the management of complex event sequences. The project distinguishes itself by providing localized Chinese translations of technical concepts, ensuring that developers can access accurate information in their preferred language. It also focuses on accessibility by packaging these materials into portab
Implements sequences of stream processing operators where the output of one function becomes the input of the next.
Hyperscript is a DOM manipulation library and HTML scripting language that functions as a logic engine and reactive UI framework. It allows for the definition of interactive behavior and client-side logic directly within HTML attributes. The system distinguishes itself through declarative web scripting and in-HTML interactive behavior, which removes the requirement for separate JavaScript files to manage element states. It utilizes a specialized syntax for data processing, employing pipe operators to filter, sort, and convert data collections within the browser. The framework provides capabi
Employs pipe operators within templates to chain data transformation functions in a linear flow.
This project is a comprehensive learning resource and technical reference for reactive programming with RxJS. It provides a structured curriculum, curated examples, and an indexed operator catalog to help developers shift from imperative to declarative programming using observable data streams and functional operators. The repository features a library of reactive UI patterns and implementation recipes. These cover practical applications such as type-ahead search, game loops, gesture-based interactions like swipe-to-refresh, and security overlays like lockscreens. The resource covers a broad
Implements sequences of stream processing operators where the output of one function becomes the input of the next.
Error-or is a library that implements the result pattern to replace exception-based control flow with structured data. It provides a discriminated union implementation that encapsulates either a successful value or an error state within a single type, ensuring that operation outcomes are treated as first-class values. The library enables functional error handling by providing a fluent interface for chaining sequential operations. This monadic pipeline composition allows developers to define dependent operations that automatically short-circuit and return an error if any individual step in the
Enables chaining of sequential operations that automatically short-circuit when an error is encountered.