RxJava2-Android-Samples - RxJava 2 Android Examples - Migration From RxJava 1 to RxJava 2 - How to use RxJava 2 in Android

•    Java

---

RxJava 2.0 has been completely rewritten from scratch on top of the Reactive-Streams specification. The specification itself has evolved out of RxJava 1.x and provides a common baseline for reactive systems and libraries. Because Reactive-Streams has a different architecture, it mandates changes to some well known RxJava types.

rxjava android rxjava2 rxandroid example sample tutorial tutorials examples samples migration migrations

FunctionalAndroidReference - Showcase project of Functional Reactive Programming on Android, using RxJava

•    Kotlin

---

FunctionalAndroidReference is a showcase project of Functional Reactive Programming on Android, using RxJava. It's a companion app to the presentation "Fully Reactive Apps" at Droidcon UK 2016.

android kotlin rxjava functional-reactive-programming

AutoDispose - Automatic binding+disposal of RxJava 2 streams.

•    Java

---

AutoDispose is an RxJava 2 tool for automatically binding the execution of RxJava 2 streams to a provided scope via disposal/cancellation.Often (especially in mobile applications), Rx subscriptions need to stop in response to some event (for instance, when Activity#onStop() executes in an Android app). In order to support this common scenario in RxJava 2, we built AutoDispose.

uber autodispose rxjava reactive-extensions reactive-streams rxandroid android kotlin lifecycle

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

Intro-To-RxJava - An extensive tutorial on RxJava

•    Java

---

This guide aims to introduce a beginner reactive programmer to the complete power of the RxJava implementation of reactive programming for the JVM. It is based on the IntroToRx guide for Rx.NET. No experience with either reactive or functional programming is needed to follow the book. Familiarity with the basics of Java is required.

RxAndroid - RxJava bindings for Android

•    Java

---

Android specific bindings for RxJava 2.This module adds the minimum classes to RxJava that make writing reactive components in Android applications easy and hassle-free. More specifically, it provides a Scheduler that schedules on the main thread or any given Looper.

rx-mvvm-android - My way to MVVM using RxJava and Android databinding

•    Kotlin

---

My way to MVVM using RxJava and Android databinding

android-databinding rxjava livedata architecture-components mvvm room viewmodel koin arrow-kt functional-reactive-programming

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

android-oss - Kickstarter for Android. Bring new ideas to life, anywhere.

•    Java

---

Welcome to Kickstarter's open source Android app! Come on in, take your shoes off, stay a while—explore how Kickstarter's native squad has built and continues to build the app, discover our implementation of RxJava in logic- filled view models, and maybe even create an issue or two. We've also open sourced our iOS app, written in Swift: check it out here. Read more about our journey to open source here.

android-development android functional-programming rxjava functional-reactive-programming frp kotlin-android

reactive-audit - Audit tool aims to provide help to the use of Reactive architecture in project implementations

•    Java

---

This audit tool aims to provide help to the use of Reactive architecture in project implementations. For reminder, when applying this approach the application must use only non-blocking APIs and, as soon as possible, return the current thread to a pool, limited by the number of CPU cores. The code must also use Java 8 concurrency utility classes CompletableFuture<>` everywhere. The frameworks Play, AKKA, Scala, RxJava or Vert.x promote this approach. Now, 603 blocking methods are detected.

Store - Android Library for Async Data Loading and Caching

•    Java

---

Store is an Android library for effortless, reactive data loading.A Store is a class that simplifies fetching, parsing, storage, and retrieval of data in your application. A Store is similar to the Repository pattern [https://msdn.microsoft.com/en-us/library/ff649690.aspx] while exposing a Reactive API built with RxJava that adheres to a unidirectional data flow.

android-library caching rxjava data-flow

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

learning-rxjava - Examples of using RxJava

•    Java

---

This project contains the examples of the 'Learning Reactive Programming With Java 8' book. Of course you'll need Git :).

RxJava2Interop - Library to convert between RxJava 1

•    Java

---

Library to convert between RxJava 1.x and 2.x reactive types.Note that 2.x Subjects and FlowableProcessors support only the same input and output types.

rxjava extensions interoperation reactive-streams

Android-RxJava - Learning RxJava for Android by example

•    Java

---

Learning RxJava for Android by example

Reactive-Billing - Lightweight reactive wrapper around In App Billing API v3 for Android

•    Java

---

Cut the hassle when implementing in-app purchases on Android. Reactive Billing is a lightweight reactive wrapper around In App Billing API v3 for Android. Reactive: Exposes the In App Billing service methods as Observable, allowing to implement easy asynchrounous callbacks and other Rx-related fun stuff.

rxjava android aidl-billing-service in-app-billing

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

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.

RxJava2Extensions - RxJava 2

•    Java

---

RxJava 2.x implementation of extra sources, operators and components and ports of many 1.x companion libraries.Support the join-patterns and async-util with functional interfaces of consumers with 3-9 type arguments and have functional interfaces of functions without the throws Exception.

reactive-streams rxjava extensions

RxKotlin - RxJava bindings for Kotlin

•    Kotlin

---

RxKotlin is a lightweight library that adds convenient extension functions to RxJava. You can use RxJava with Kotlin out-of-the-box, but Kotlin has language features (such as extension functions) that can streamline usage of RxJava even more. RxKotlin aims to conservatively collect these conveniences in one centralized library, and standardize conventions for using RxJava with Kotlin.Chapter 12 of Learning RxJava covers RxKotlin and Kotlin idioms with RxJava.

kotlin rxjava