RxFunctions

Observable pipeline builder

A library for composing and chaining functions on Observables in RxJava to simplify complex data processing pipelines.

Advanced Function composition to use with RxJava [STABLE]

GitHub

49 stars
5 watching
1 forks
Language: Java
last commit: almost 8 years ago
Linked from 1 awesome list


Backlinks from these awesome lists:

Related projects:

Repository Description Stars
pakoito/rxcomprehensions A set of methods to simplify and reduce boilerplate code in RxJava Observable chains 85
pakoito/rxpartialapplication A library to partially apply functions on RxJava primitives. 30
pakoito/rxactions Provides a functional way to compose actions in an RxJava observable chain for smooth handling of side effects 33
pakoito/rxtuples Library providing tuple-like data structures to simplify RxJava usage and operations 112
pakoito/rxcurrying A library for currying and simplifying function calls in RxJava 38
davidmoten/rxjava-file A Java library providing observables for file I/O and event handling using RxJava and NIO. 82
ribot/assertj-rx Provides assertions for testing RxJava Observables in Java 117
android10/frodo A tool for logging RxJava Observables and Subscribers in Android apps. 1,474
reactivex/rxjavafx A library that provides a bridge between RxJava and JavaFX event handling 520
quintoandar/butterfree A Python library for building data pipelines to create and load features into a feature store using Apache Spark. 288
datasalt/pangool A Java framework that simplifies Hadoop's MapReduce API to build efficient data processing pipelines 57
reactivex/rxjavacomputationexpressions RxJava provides a way to compose and manage asynchronous data streams using computation expressions. 60
davidmoten/rxjava-jdbc An efficient execution and functional composition of database calls using JDBC and RxJava Observables. 805
reactivex/rxjavamath Math operators for RxJava's functional programming framework 97
kievsash/rxjs-toolbox A set of custom operators and handy factory functions for managing asynchronous data flows 10