Awesome GitHub RepositoriesSequence Buffering

Reactor Core este un toolkit de programare reactivă și o fundație non-blocking pentru compunerea pipeline-urilor de date asincrone pe JVM. Servește drept framework de procesare a fluxurilor asincrone și sistem de gestionare a backpressure-ului, permițând dezvoltatorilor să transforme, filtreze și combine secvențe de evenimente în timp ce reglează fluxul de date între producători și consumatori pentru a preveni epuizarea resurselor. Biblioteca se diferențiază printr-un sistem sofisticat de programare a concurenței și control al fluxului bazat pe cerere. Decuplează procesarea semnalelor de firele de execuție specifice folosind un registru de scheduler și oferă mecanisme pentru propagarea metadatelor imutabile conștiente de context peste limitele asincrone. De asemenea, dispune de instrumente specializate pentru capturarea urmelor la momentul asamblării și programarea timpului virtual pentru a facilita testarea operatorilor bazați pe timp. Proiectul acoperă o gamă largă de capabilități, inclusiv procesarea funcțională a datelor pentru agregarea și windowing-ul secvențelor, o varietate de strategii de recuperare a erorilor precum reîncercările cu backoff exponențial și utilitare pentru a conecta API-urile legacy de tip callback sau sincrone în fluxuri reactive. Oferă, de asemenea, instrumente pentru monitorizarea pipeline-ului și o suită de instrumente de testare pentru verificarea secvențelor de semnale.

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.

Acest proiect este o bibliotecă de comunicare în infraroșu și un driver hardware pentru microcontrolerele Arduino. Oferă sistemele de bază necesare pentru a trimite și primi semnale infraroșii, acționând atât ca un decodor de semnal care parsează impulsurile de lumină în adrese și comenzi structurate, cât și ca un generator de semnal pentru transmiterea codurilor. Biblioteca permite capturarea datelor de sincronizare brute pentru a analiza protocoale infraroșii necunoscute și a recrea modele de comunicare specifice. Suportă transmiterea codurilor folosind protocoale predefinite, scheme de codificare personalizate sau array-uri de sincronizare brute. Sistemul acoperă o gamă largă de capabilități de procesare a semnalului, inclusiv recepția semnalului bazată pe întreruperi, analiza sincronizării lățimii impulsului și un mecanism de dispecerizare pentru maparea comenzilor primite către funcții software. Include, de asemenea, suport pentru gestionarea mai multor instanțe de receptor pe un singur procesor.

Reactor is a reactive streams library and framework for building asynchronous data pipelines. It provides a system for coordinating execution contexts via an asynchronous event-loop manager, alongside a set of reactive abstractions for implementing high-performance TCP, UDP, QUIC, and HTTP services. The project includes a specialized testing tool for verifying the timing and order of asynchronous data flows and a bill of materials to synchronize compatible versions of core reactive libraries and networking add-ons. Its capability surface covers non-blocking network services, demand-based bac