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.
RxJava 2 Android Examples:
This project contains RxJava 2 implementations of the sample operators found in the RxMarbles Android Application.
Library to convert between RxJava 1.x and 2.x reactive types.
Kotlin Adaptor for RxJava.
Kotlin has support for SAM (Single Abstract Method) Interfaces as Functions (i.e. Java 8 Lambdas). So you could use Kotlin in RxJava without this adaptor
compose() your Observables into ones that load data that's cached across activity orientation changes without leaking your Activity and without you having to worry about unsubscribing.
RxLoader caches the data emitted by your Observable across orientation changes by utilizing an Android Loader, while also providing the results from an Observable preserving the RxJava pattern.
This is a collection of samples demonstrating the use of operators in RxJava 2.0 and RxKotlin.
This library implements reactive paging and loading. It helps to handle the states of loading a simple data (LCE - loading/content/error) or the complex states of lists with pagination (PLCE - paging/loading/content/error). The solution is based on the usage of Unidirectional Data Flow pattern.
RxPartialApplication is a library to allow partial application on RxJava function primitives.
A Promise wrapper around RxJava's Observable. A promise represents a future value (usually of an asynchronous operation).
An RxJava transformer which combines replay, publish, and refCount operators.
This project is implementation of ideas from Managing state reactive way article.
RxTuples is a library to smooth RxJava usage by adding simple Tuple creation functions.
An RxJava 2 operator which splits an observable into windows using a key selector.
An application that helps you learn and better understand ReactiveX on Android.