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

bacon.js - FRP (functional reactive programming) library for Javascript

•    CoffeeScript

---

A small functional reactive programming lib for JavaScript.

bacon.js bacon frp functional reactive programming stream streams eventstream rx rxjs observable reactive-library functional-reactive

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

marble - Marble

•    TypeScript

---

Functional reactive HTTP middleware framework built on top of Node.js platform, TypeScript and RxJS library. If you don't have any experience with functional reactive programming, we strongly recommend to gain some basic overview first with ReactiveX intro or with The introduction to Reactive Programming you've been missing written by @andrestaltz.

marble-diagrams rxjs typescript nodejs reactive marble stream observable api

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.

MobX - Simple, scalable state management.

•    Javascript

---

MobX is a battle tested, simple and scalable state management library transparently applying functional reactive programming (TFRP). The Mobx design principle is very simple: Anything that can be derived from the application state, should be derived. Automatically. This includes the UI, data serialization, server communication, etc.

mobx reactive-programming react typescript mobservable observable react-component reactjs reactive model frp functional-reactive-programming state-management data-flow reactive-library functional-reactive streams

thisless-react - Reactive React application flow with React, RxJS and Redux

•    

---

Reactive React application flow, with React, RxJS and Redux. Fully Reactive: With RxJS and React Reactive Class, components are made reactive and observable.

RxGo - Reactive Extensions for the Go language.

•    Go

---

All contributions are welcome, both in development and documentation! Be sure you check out contributions and roadmap.ReactiveX, or Rx for short, is an API for programming with observable streams. This is a ReactiveX API for the Go language.

reactivex goroutines stream observable-streams observable

Monix - Asynchronous Programming for Scala and Scala.js

•    Scala

---

Monix is a high-performance Scala / Scala.js library for composing asynchronous and event-based programs, exposing high-level types, such as observable sequences that are exposed as asynchronous streams, expanding on the observer pattern, strongly inspired by ReactiveX and by Scalaz, but designed from the ground up for back-pressure and made to cleanly interact with Scala’s standard library, compatible out-of-the-box with the Reactive Streams protocol.

asynchronous reactive streams reactive-scala async

redux-observable - RxJS middleware for action side effects in Redux using "Epics"

•    Javascript

---

RxJS 5-based middleware for Redux. Compose and cancel async actions to create side effects and more.This has peer dependencies of rxjs@5.x.x and redux, which will have to be installed as well.

rx ducks reducks redux middleware observable thunk async cancel action reactive rxjs

Cyclejs - A functional and reactive JavaScript framework for predictable code

•    Typescript

---

Functional enables “predictable” code, and Reactive enables “separated” code. Cycle.js apps are made of pure functions, which means you know they only take inputs and generate predictable outputs, without performing any I/O effects. The building blocks are reactive streams from libraries like xstream, RxJS or Most.js, which greatly simplify code related to events, asynchrony, and errors.

framework reactive-programming rxjs cyclejs functional-programming reactive

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

SignalKit - SignalKit is a reactive Swift framework with focus on clean and readable API.

•    Swift

---

SignalKit is a lightweight event and binding framework. The core of SignalKit is the Observable protocol. Each implementation of the Observable protocol defines the type of the observation thus an Observable can sendNext only one type of event. For example an Observable of type String can only sendNext String values. Another key protocol is SignalType which implements Observable and Disposable. Each SignalType implementation has a property disposableSource: Disposable? which points to a Disposable that comes before the current signal.

signal reactive observer unidirectional protocol-oriented

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

Interstellar - Simple and lightweight Functional Reactive Coding in Swift for the rest of us

•    Swift

---

The simplest Observable<T> implementation for Functional Reactive Programming you will ever find. This library does not use the term FRP (Functional Reactive Programming) in the way it was defined by Conal Elliot, but as a paradigm that is both functional and reactive. Read more about the difference at Why I cannot say FRP but I just did.

DynamicData - Reactive collections based on Rx.Net

•    CSharp

---

Dynamic Data is a portable class library which brings the power of Reactive Extensions (Rx) to collections. Rx is extremely powerful but out of the box provides nothing to assist with managing collections. In most applications there is a need to update the collections dynamically. Typically a collection is loaded and after the initial load, asynchronous updates are received. The original collection will need to reflect these changes. In simple scenarios the code is simple. However, typical applications are much more complicated and may apply a filter, transform the original dto and apply a sort. Even with these simple every day operations the complexity of the code is quickly magnified. Dynamic data has been developed to remove the tedious code of dynamically maintaining collections. It has grown to become functionally very rich with at least 60 collection based operations which amongst other things enable filtering, sorting, grouping, joining different sources, transforms, binding, pagination, data virtualisation, expiration, disposal management plus more.

reactive-extensions reactive-collections rx dynamic-data rx-observable mvvm reactive-programming

DynamicData - Reactive collections based on Rx.Net

•    CSharp

---

Dynamic Data is a portable class library which brings the power of Reactive Extensions (Rx) to collections. Rx is extremely powerful but out of the box provides nothing to assist with managing collections. In most applications there is a need to update the collections dynamically. Typically a collection is loaded and after the initial load, asynchronous updates are received. The original collection will need to reflect these changes. In simple scenarios the code is simple. However, typical applications are much more complicated and may apply a filter, transform the original dto and apply a sort. Even with these simple every day operations the complexity of the code is quickly magnified. Dynamic data has been developed to remove the tedious code of dynamically maintaining collections. It has grown to become functionally very rich with at least 60 collection based operations which amongst other things enable filtering, sorting, grouping, joining different sources, transforms, binding, pagination, data virtualisation, expiration, disposal management plus more.

reactivex mvvm reactive-programming reactive-extensions rx hacktoberfest dynamic-data rx-observable reactive-collections dynamicdata

Rx (Reactive Extensions)

•    LINQ

---

The Reactive Extensions (Rx) is a library for composing asynchronous and event-based programs using observable sequences and LINQ-style query operators.

reactive-extensions rx ix observable

RxJava - Reactive Extensions for the JVM

•    Java

---

RxJava is a Java VM implementation of Reactive Extensions: a library for composing asynchronous and event-based programs by using observable sequences. It extends the observer pattern to support sequences of data/events and adds operators that allow you to compose sequences together declaratively while abstracting away concerns about things like low-level threading, synchronization, thread-safety and concurrent data structures.

reactive reactive-programming asynchronous events async

refract - Harness the power of reactive programming to supercharge your components

•    TypeScript

---

Handle your component effects and side-effects in a clear and declarative fashion by using asynchronous data streams (reactive programming). Component-based architecture and functional programming have become an increasingly popular approach for building UIs. They help make apps more predictable, more testable, and more maintainable.

reactive-programming react preact inferno redux rxjs callbag most xstream typescript