RxMarbles - RxMarbles iOS app

•    Swift

---

Interactive diagrams of Rx Observables. ReactiveX is a library for composing asynchronous and event-based programs by using observable sequences.

rxviz - Rx Visualizer - Animated playground for Rx Observables

•    Javascript

---

RxViz simply visualizes a given Observable. Your JavaScript code will be evaluated, and, if the last expression is an Observable, a nice animated visualization will appear. RxViz treats the evaluated Observable as a black box. We rely only on the fact that Observable emits values over time. RxViz doesn't rely on the internals of RxJS. This will allow us to visualize TC39 Observables in the future.

rx observable rxjs reactive stream visualizer visualization svg animation react react-component

RxRuby - Reactive Extensions for Ruby

•    Ruby

---

Reactive Programming is a hot topic as of late, especially with such things as the Reactive Manifesto. Applications' needs have changed over time, from simple polling for data to a full reactive system where data is pushed at you. Each time, we're adding more complexity, data, and asynchronous behavior to our applications. How do we manage it all? How do we scale it? By moving towards "Reactive Architectures" which are event-driven, resilient, and responsive. With the Reactive Extensions, you have all the tools you need to help build these systems.The Reactive Extensions for Ruby (RxRuby) is a set of libraries for composing asynchronous and event-based programs using observable sequences and fluent query operators that many of you already know in Ruby. Using RxRuby, developers represent asynchronous data streams with Observables, query asynchronous data streams using our many operators, and parameterize the concurrency in the asynchronous data streams using Schedulers. Simply put, RxRuby = Observables + Operators + Schedulers.

RxPY - Reactive Extensions for Python

•    Python

---

Reactive Extensions for Python (RxPY) is a set of libraries for composing asynchronous and event-based programs using observable sequences and LINQ-style query operators in Python. Using Rx, developers represent asynchronous data streams with Observables, query asynchronous data streams using operators, and parameterize concurrency in data/event streams using Schedulers.Using Rx, you can represent multiple asynchronous data streams (that come from diverse sources, e.g., stock quote, Tweets, computer events, web service requests, etc.), and subscribe to the event stream using the Observer object. The Observable notifies the subscribed Observer instance whenever an event occurs.You can put various transformations in-between the source Observable and the consuming Observer as well.

reactive reactivex reactive-extensions rxpy

RxPHP - Reactive extensions for PHP

•    PHP

---

Reactive extensions for PHP. The reactive extensions for PHP are a set of libraries to compose asynchronous and event-based programs using observable collections and LINQ-style query operators in PHP.note: This repo is for v2.x, the latest version of RxPHP, not v1.x.

rxphp reactivex observables asynchronous

yatrum - Yatrum - Share and Discover Travel Stories, Itineraries, Travel Guides built with ♥️ using Angular 4

•    TypeScript

---

Yatrum built with ❤️ using Angular2, ngrx store, observables and reactive forms. We have also created and open sourced AngularSpree: Plug and play frontend application for SPREE E-Commerce API built with ❤️ using Angular2, Redux, Observables & ImmutableJs.

angular redux ngrx opensource angular-2 aviabird

ReactiveNetwork - Android library listening network connection state and Internet connectivity with RxJava Observables

•    Java

---

ReactiveNetwork is an Android library listening network connection state and Internet connectivity with RxJava Observables. It's a successor of Network Events library rewritten with Reactive Programming approach. Library supports both new and legacy network monitoring strategies. Min sdk version = 9. Please note: Due to memory leak in WifiManager reported in issue 43945 in Android issue tracker it's recommended to use Application Context instead of Activity Context.

android internet-connection network-connection network-monitoring wifi network internet rxjava rxjava2 rxandroid rxandroid2

callbag-basics - 👜 Tiny and fast reactive/iterable programming library

•    Javascript

---

Basic callbag factories and operators to get started with. Callbag is just a spec, but callbag-basics is a real library you can use. Imagine a hybrid between an Observable and an (Async)Iterable, that's what callbags are all about. In addition, the internals are tiny because it's all done with a few simple callbacks, following the callbag spec. As a result, it's tiny and fast.

callbacks reactive iterables observables callbag callback standard spec observable iterable

mobius - A functional reactive framework for managing state evolution and side-effects.

•    Java

---

Mobius is a functional reactive framework for managing state evolution and side-effects, with add-ons for connecting to Android UIs and RxJava Observables. It emphasizes separation of concerns, testability, and isolating stateful parts of the code. To learn more, see the wiki for a user guide. To see Mobius in action, check out the sample TODO app based on the app from Android Architecture Blueprints. You can also watch a talk from Android @Scale introducing Mobius.

platform - Reactive libraries for Angular

•    TypeScript

---

Become a sponsor and get your logo on our README on Github with a link to your site. Please read contributing guidelines here.

ngrx rxjs angular observables reactive state-management redux

RxRealm - RxSwift extension for RealmSwift's types

•    Swift

---

This library is a thin wrapper around RealmSwift ( Realm Docs ). RxRealm can be used to create Observables from objects of type Results, List, LinkingObjects or AnyRealmCollection. These types are typically used to load and observe object collections from the Realm Mobile Database.

realm rxswift realmswift database reactive

angularspree - Angular(6+) E-Commerce front-end framework

•    TypeScript

---

AngularSpree Plug and play frontend application for SPREE E-Commerce API built with ❤️ using Angular6, Redux, Observables & ImmutableJs. AngularSpree is an open source Angular(6.x+) front-end application for Spree Commerce. It's free and always will be.

angular spree spree-ecommerce ngrx ngrx-store reactive-programming frontend progressive-web-app aviabird

RxLocation - 🗺 Reactive Location APIs Library for Android and RxJava 2

•    Java

---

This library wraps the Location APIs in RxJava 2 Observables, Singles, Maybes and Completables. No more managing GoogleApiClients! Also, the resolution of the location settings check is optionally handled by the lib. For RxJava 1, please take a look at the Android-ReactiveLocation library by Michał Charmas.

android rxjava2 location location-services google-play-services googleapiclient

mobx-react-lite - Lightweight React bindings for MobX based on React 16.8 and Hooks

•    TypeScript

---

This is a next iteration of mobx-react coming from introducing React hooks which simplifies a lot of internal workings of this package. Class based components are not supported except using <Observer> directly in class render method. If you want to transition existing projects from classes to hooks (as most of us do), you can use this package alongside the mobx-react just fine. The only conflict point is about the observer HOC. Subscribe to this issue for a proper migration guide.

react mobx react-hooks observables mobservable react-component reactjs reactive hooks observer useobserver usecomputer

dom-expressions - A Fine-Grained Runtime for Performant DOM Rendering

•    Javascript

---

DOM Expressions is a Rendering Runtime for reactive libraries that do fine grained change detection. These libraries rely on concepts like Observables and Signals rather than Lifecycle functions and the Virtual DOM. Standard JSX transformers are not helpful to these libraries as they need to evaluate their expressions in isolation to avoid re-rendering unnecessary parts of the DOM. This package wraps libraries like KnockoutJS or MobX and use them independent of their current render systems using a small library to render pure DOM expressions. This approach has been proven to be incredibly fast, dominating the highest rankings in the JS Framework Benchmark.

alpakka - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka

•    Scala

---

Systems don't come alone. In the modern world of microservices and cloud deployment, new components must interact with legacy systems, making integration an important key to success. Reactive Streams give us a technology-independent tool to let these heterogeneous systems communicate without overwhelming each other. The Alpakka project is an open source initiative to implement stream-aware, reactive, integration pipelines for Java and Scala. It is built on top of Akka Streams, and has been designed from the ground up to understand streaming natively and provide a DSL for reactive and stream-oriented programming, with built-in support for backpressure. Akka Streams is a Reactive Streams and JDK 9+ java.util.concurrent.Flow-compliant implementation and therefore fully interoperable with other implementations.

integration reactive akka akka-stream akka-streams-connectors reactive-streams messaging

ReactiveUI - An advanced, composable, functional reactive model-view-viewmodel framework for all

•    CSharp

---

ReactiveUI is a composable, cross-platform model-view-viewmodel framework for all .NET platforms that is inspired by functional reactive programming which is a paradigm that allows you to abstract mutable state away from your user interfaces and express the idea around a feature in one readable place and improve the testability of your application.That's reactive programming: changes propagate throughout a system automatically. Welcome to the peanut butter and jelly of programming paradigms. For further information please watch the this video from the Xamarin Evolve conference - Why You Should Be Building Better Mobile Apps with Reactive Programming by Michael Stonis.

reactiveui xamarin ios android uwp winforms reactive-programming reactive-extensions functional-reactive-programming mvvm framework first-timers xamarin-forms tizen sponsorship opencollective

spring-reactive-sample - Spring 5 Reactive playground

•    Java

---

Reactive or Reactive Streams is a hot topic in these days, you can see it in blog entries, presentations, or some online course. Reactive Streams is an initiative to provide a standard for asynchronous stream processing with non-blocking back pressure.This encompasses efforts aimed at runtime environments (JVM and JavaScript) as well as network protocols.

spring-webflux kotlin spring-boot reactive-streams spring-data spring-data-mongodb-reactive spring-data-redis spring-data-cassandra rxjava rxjava2 spring-security spring-session reactor spring

Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka

•    Scala

---

The Alpakka project is an open source initiative to implement stream-aware, reactive, integration pipelines for Java and Scala. It is built on top of Akka Streams, and has been designed from the ground up to understand streaming natively and provide a DSL for reactive and stream-oriented programming, with built-in support for backpressure. Akka Streams is a Reactive Streams and JDK 9+ java.util.concurrent.Flow-compliant implementation and therefore fully interoperable with other implementations.

kafka reactive-streams akka akka-streams reactive kafka-client kafka-connector

fair-analytics - 📊 An analytics server that doesn't undermine user's privacy

•    Javascript

---

Google Analytics is the de-facto standard in the web and mobile analytics service world.Inspired by an interesting article from @staltz, and from the awesome work done by the micro-analytics team, I decided to start working on a Google Analytics alternative.

analytics p2p distributed ga fair nodejs privacy api google