6 repository-uri
Combining multiple asynchronous computations into a single operation where the output of one determines the next.
Distinct from Asynchronous Task Runners: Distinct from Asynchronous Task Runners: focuses on the functional composition and chaining of computations rather than the execution management of background tasks.
Explore 6 awesome GitHub repositories matching development tools & productivity · Asynchronous Task Composition. Refine with filters or upvote what's useful.
fp-ts is a TypeScript library that brings pure functional programming patterns to the language through algebraic data types, type class abstractions, and composable combinators. It provides foundational data types like Option for optional values, Either for typed error handling, and Task for lazy asynchronous computations, all designed to make invalid states unrepresentable and side effects explicit. The library is built on category theory concepts, offering type classes such as Functor, Applicative, Monad, Semigroup, and Monoid with lawful instances for common data structures. The library di
Chains tasks so the output of one feeds into the next, preserving only the final result.
Asio is a C++ library for performing network and low-level I/O operations using a consistent asynchronous model that avoids blocking program execution. It provides a portable, cross-platform interface for network socket communication across different operating systems, and manages multiple asynchronous operations without requiring explicit thread management or locking. The library implements a proactor-based asynchronous model where operations post completion handlers to a queue for later execution, and wraps operating system I/O multiplexing mechanisms like epoll, kqueue, IOCP, and select in
Chains multiple async tasks together using a consistent pattern to simplify complex input/output workflows.
Concurrent Ruby is a comprehensive concurrency toolkit for the Ruby language that provides thread-safe data structures, synchronization primitives, and asynchronous execution patterns. It implements core concurrency abstractions including an actor model framework where isolated actors communicate through asynchronous message passing, a future and promise system for composing non-blocking operations, and thread pool executors that manage reusable worker threads for concurrent task execution. The library distinguishes itself through a broad set of coordination mechanisms that go beyond basic th
Chains dependent tasks together so the output of one future feeds into the next, handling success and failure paths.
Beast este o bibliotecă C++ pentru implementarea clienților și serverelor HTTP și WebSocket de nivel scăzut. Acesta funcționează ca un framework de rețea asincron conceput pentru a compune operațiuni I/O non-blocante și stive de fluxuri stratificate pentru gestionarea traficului de rețea concurent, utilizând în mod specific modelul asincron Boost.Asio. Biblioteca oferă o implementare cuprinzătoare a protocoalelor HTTP/1.1 și WebSocket. Pentru HTTP, include primitive pentru parsarea și serializarea mesajelor cu suport pentru codificarea transferului fragmentat (chunked), citirea incrementală a corpului și pipelining-ul cererilor. Implementarea sa WebSocket acoperă întregul ciclu de viață al comunicării bidirecționale, inclusiv handshake-uri, negocierea subprotocolului, fragmentarea mesajelor și monitorizarea stării prin cadre de control. Beast include o suită specializată de instrumente pentru gestionarea buffer-elor de rețea pentru a optimiza I/O scatter-gather prin buffer-e de memorie dinamice și bazate pe secvențe. De asemenea, acoperă comunicarea securizată în rețea prin integrarea straturilor SSL/TLS pentru fluxuri criptate, autentificarea certificatelor și terminarea securizată a conexiunilor. Framework-ul oferă abstracții cross-platform pentru I/O de fișiere și gestionarea semnalelor de sistem pentru a susține dezvoltarea stabilă a aplicațiilor de rețea.
Combines multiple intermediate asynchronous actions into a single initiating function.
Acest proiect este un framework cuprinzător pentru dezvoltarea aplicațiilor iOS, axat pe construirea de aplicații mobile care dispun de componente UI personalizate, gestionarea sarcinilor asincrone și persistența datelor locale. Servește drept bază de cunoștințe tehnice pentru ingineria software, oferind instrumente pentru a organiza și publica analize arhitecturale și note în format Markdown. Framework-ul se distinge printr-un strat de stocare robust bazat pe documente, care utilizează înregistrări formatate BSON pentru a efectua operațiuni CRUD într-un magazin de documente NoSQL. Oferă capabilități extinse de integrare a sistemului, inclusiv comunicarea specializată prin extensii de aplicație, trecerea mesajelor între sandbox-uri și prezentarea nativă a share sheet-ului, permițând o interacțiune fluidă între aplicația gazdă și serviciile la nivel de sistem. Proiectul acoperă o suprafață largă de capabilități, inclusiv gestionarea avansată a concurenței cu sincronizare thread-safe, descărcarea randării UI în fundal pentru a menține responsivitatea și suport cuprinzător pentru internaționalizare. Include, de asemenea, utilitare axate pe dezvoltatori pentru generarea de tipuri statice, maparea automată a resurselor și construcția de prototipuri interactive, alături de instrumente specializate pentru monitorizarea beacon-urilor geografice și generarea adaptivă de grafice.
Sequences multiple asynchronous operations by passing the result of one task to the next using a standardized mechanism.
This project is a library of algorithms for transforming, filtering, and combining asynchronous data streams in Swift. It provides a toolkit for managing asynchronous sequences, offering a concurrent sequence processor to merge, zip, and concatenate multiple streams into single outputs. The library distinguishes itself through specialized timing and flow control mechanisms. It implements asynchronous back-pressure to synchronize producer and consumer speeds and provides a toolkit for event timing, including debouncing, throttling, and the generation of periodic timers. The capability surface
Provides utilities to wrap and transform asynchronous streams while maintaining lazy evaluation.