9 Repos
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 is a functional reactive programming library and an implementation of ReactiveX for the Go language. It serves as an asynchronous stream processing toolkit designed to coordinate event-based programs and data flows using the observable pattern. The library enables the construction of asynchronous processing pipelines that transform, filter, and combine event sequences. It distinguishes itself through the use of functional operators to compose these pipelines and provides mechanisms for managing concurrent execution. The toolkit covers a broad range of stream orchestration capabilities,
Links discrete processing functions into sequences where data flows from one operator to the next.
RxPY ist eine Bibliothek für funktionale reaktive Programmierung und eine ReactiveX-Observable-Bibliothek für Python. Sie dient als asynchroner Stream-Prozessor und ereignisgesteuertes Koordinations-Framework zum Aufbau von Datenpipelines, die auf Zustandsänderungen oder Ereignisströme im Zeitverlauf reagieren. Die Bibliothek bietet ein Toolkit zur Komposition asynchroner und ereignisbasierter Programme mittels beobachtbarer Sequenzen und Operatoren. Sie zeichnet sich durch konfigurierbare Scheduler aus, die Nebenläufigkeit, Timing und Abonnement-Lebenszyklen verwalten. Das Projekt deckt ein breites Spektrum an Stream-Processing-Funktionen ab, einschließlich Datenaggregation, Filterung und Kombination. Es bietet Mechanismen für Event-Broadcasting, Sequenz-Buffering und Fehlerbehandlung sowie Werkzeuge zur Koordination beobachtbarer Streams mit asynchronen Event-Loops. Tests und Qualitätssicherung werden durch virtuelle Zeitsimulation, Marble-Diagramm-Modellierung und Emissionsverifizierung unterstützt.
Enables declarative pipeline composition where the output of one stream operator becomes the input of the next.
Dieses Repository ist eine Sammlung praktischer Implementierungsmuster und Referenzbeispiele für die Verwendung von RxJava 2 zur Verwaltung asynchroner Datenströme in Android-Anwendungen. Es dient als Leitfaden für die Implementierung reaktiver Programmierung und bietet Codebeispiele für den Umgang mit komplexer ereignisgesteuerter Logik und asynchronen Mustern in mobilen Umgebungen. Das Projekt zeichnet sich dadurch aus, dass es spezifische Referenzimplementierungen für häufige mobile Herausforderungen bietet, wie z. B. Echtzeitsuche mit Debouncing, On-Demand-Listen-Pagination für unendliches Scrollen und Cache-First-Datenstreaming zur Reduzierung wahrgenommener Ladezeiten. Es enthält zudem Beispiele für Event-Bus-Architekturen für entkoppelte Anwendungskommunikation. Die Codebasis deckt ein breites Spektrum reaktiver Fähigkeiten ab, einschließlich des Managements von Abonnement-Lebenszyklen zur Vermeidung von Speicherlecks, Thread-Switching mittels Schedulern und der Verwendung funktionaler Operatoren zur Transformation und Kombination von Datenströmen. Es demonstriert zudem asynchrone Netzwerkkoordination und die Verwendung von Composite Disposables für die Gruppenverwaltung von Abonnements.
Uses functional operators in chains to filter, map, and combine asynchronous data emissions.
Scriban ist eine Text-Templating-Bibliothek und eine .NET-Skript-Engine zur dynamischen Textgenerierung. Sie fungiert als Template-Prozessor und sichere Skript-Sandbox und bietet eine sichere Ausführungsumgebung, die den Zugriff auf Objekte einschränkt, um unautorisierte Codeausführung zu verhindern. Das Projekt enthält zudem einen Template-Parser für abstrakte Syntaxbäume, der eine programmatische Analyse und Modifikation von Templates ermöglicht. Die Engine verfügt über eine dedizierte Liquid-Template-Engine und einen Kompatibilitätsmodus, der das Parsen, Ausführen und Konvertieren von Templates in Liquid-Syntax ermöglicht. Sie zeichnet sich durch ein Filter-System für Member-Zugriffe aus, das es Entwicklern erlaubt, Objekteigenschaften umzubenennen, zu verbergen oder zu filtern, um zu steuern, wie Daten innerhalb von Templates zugegriffen werden. Die Bibliothek deckt ein breites Spektrum an Funktionen ab, einschließlich asynchronem Template-Rendering, bedingter Logik und Iteration über Sammlungen. Sie bietet integrierte Dienstprogramme zur Datenmanipulation, wie mathematische Operationen, JSON-Konvertierung, Datums- und Zeitarithmetik sowie umfangreiche Textverarbeitung mittels regulärer Ausdrücke. Entwickler können die Engine durch die Definition eigener Funktionen und die Integration externer Klassen weiter erweitern. Das Projekt bietet eine sichere API-Oberfläche, um die Veröffentlichung als native Binärdatei via Native AOT zu unterstützen.
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.