RxGroovy: Reactive Extensions for Groovy

This is a Groovy adapter to RxJava.

This adaptor allows ‘groovy.lang.Closure’ functions to be used and RxJava will know how to invoke them.

This enables code such as:

  Observable.just("one", "two", "three")
    .take(2) 
    .subscribe({arg -> println(arg)})

Master Build Status

Since RxGroovy is part of the RxJava family the communication channels are similar:

RxGroovy 1.0.x is based on RxJava 1.0.x. As of 1.0.0 semantic versioning will be used.

RxJava:

For version 1.x:

Binaries and dependency information for Maven, Ivy, Gradle and others can be found at https://search.maven.org.

Example for Maven:

<dependency>
    <groupId>io.reactivex</groupId>
    <artifactId>rxgroovy</artifactId>
    <version>x.y.z</version>
</dependency>

and for Ivy:

<dependency org="io.reactivex" name="rxgroovy" rev="x.y.z" />

and for Gradle:

compile 'io.reactivex:rxgroovy:x.y.z'

To build:

$ git clone git@github.com:ReactiveX/RxGroovy.git
$ cd RxGroovy/
$ ./gradlew build

Futher details on building can be found on the RxJava Getting Started page of the wiki.

For bugs, questions and discussions please use the Github Issues.