9 repository-uri
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 este o bibliotecă de programare reactivă funcțională și o implementare a ReactiveX pentru limbajul Go. Servește ca un toolkit de procesare a fluxurilor asincrone conceput pentru a coordona programele bazate pe evenimente și fluxurile de date folosind modelul observabil. Biblioteca permite construirea de pipeline-uri de procesare asincronă care transformă, filtrează și combină secvențe de evenimente. Se remarcă prin utilizarea operatorilor funcționali pentru a compune aceste pipeline-uri și oferă mecanisme pentru gestionarea execuției concurente. Toolkit-ul acoperă o gamă largă de capabilități de orchestrare a fluxurilor, inclusiv agregarea datelor, combinarea multi-flux și conversia fluxurilor în structuri de date statice. Include suport integrat pentru recuperarea erorilor, controlul backpressure-ului pentru a regla vitezele de producție a datelor și worker pooling pentru paralelizarea procesării pe nucleele CPU.
Links discrete processing functions into sequences where data flows from one operator to the next.
RxPY este o bibliotecă de programare reactivă funcțională și o bibliotecă de tip ReactiveX observable pentru Python. Acesta servește drept procesor de fluxuri asincrone și framework de coordonare bazat pe evenimente, utilizat pentru a construi pipeline-uri de date care reacționează la schimbările de stare sau la fluxurile de evenimente în timp. Biblioteca oferă un set de instrumente pentru compunerea programelor asincrone și bazate pe evenimente folosind secvențe observabile și operatori. Se distinge prin utilizarea de schedulere configurabile pentru a gestiona concurența, sincronizarea și ciclurile de viață ale abonamentelor. Proiectul acoperă o gamă largă de capabilități de procesare a fluxurilor, inclusiv agregarea, filtrarea și combinarea datelor. Oferă mecanisme pentru difuzarea evenimentelor, buffering-ul secvențelor și gestionarea erorilor, precum și instrumente pentru coordonarea fluxurilor observabile cu bucle de evenimente asincrone. Testarea și asigurarea calității sunt susținute prin simularea timpului virtual, modelarea cu diagrame marble și verificarea emisiilor.
Enables declarative pipeline composition where the output of one stream operator becomes the input of the next.
Acest repository este o colecție de tipare practice de implementare și exemple de referință pentru utilizarea RxJava 2 în gestionarea fluxurilor de date asincrone în aplicațiile Android. Servește drept ghid de implementare a programării reactive, oferind exemple de cod pentru gestionarea logicii complexe bazate pe evenimente și a tiparelor asincrone în medii mobile. Proiectul se distinge prin furnizarea de implementări de referință specifice pentru provocări mobile comune, cum ar fi căutarea în timp real cu debouncing, paginarea listelor la cerere pentru scroll infinit și streaming-ul de date cache-first pentru a reduce timpii de încărcare percepuți. Include, de asemenea, exemple de arhitecturi de tip event bus pentru comunicarea decuplată a aplicației. Codul sursă acoperă o gamă largă de capabilități reactive, inclusiv gestionarea ciclului de viață al abonamentelor pentru a preveni scurgerile de memorie, comutarea thread-urilor prin schedulere și utilizarea operatorilor funcționali pentru transformarea și combinarea fluxurilor de date. Demonstrează în continuare coordonarea rețelei asincrone și utilizarea composite disposables pentru gestionarea abonamentelor de grup.
Uses functional operators in chains to filter, map, and combine asynchronous data emissions.
Scriban este o bibliotecă de șabloane text și un motor de scripting .NET utilizat pentru generarea dinamică de text. Funcționează ca un procesor de șabloane și un sandbox de scripting sigur, oferind un mediu de execuție securizat care restricționează expunerea obiectelor pentru a preveni execuția neautorizată de cod. Proiectul include, de asemenea, un parser de șabloane cu arbore sintactic abstract (AST) care permite analiza și modificarea programatică a șabloanelor. Motorul dispune de un motor de șabloane Liquid dedicat și mod de compatibilitate, permițându-i să parseze, execute și convertească șabloane scrise în sintaxa Liquid. Se distinge printr-un sistem de filtrare a expunerii membrilor care permite dezvoltatorilor să redenumească, ascundă sau filtreze proprietățile obiectelor pentru a controla modul în care datele sunt accesate în șabloane. Biblioteca acoperă o gamă largă de capabilități, inclusiv randarea asincronă a șabloanelor, logica condiționată și iterarea colecțiilor. Oferă utilitare integrate pentru manipularea datelor, cum ar fi operațiuni matematice, conversie JSON, aritmetică de dată și oră și procesare extinsă de text folosind expresii regulate. Dezvoltatorii pot extinde motorul prin definirea de funcții personalizate și integrarea claselor externe. Proiectul oferă o suprafață API sigură pentru a susține publicarea ca binar nativ prin 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.