RxQuasar

Integrates RxJava with Quasar. Includes a fiber (lightweight-thread) based scheduler, and an Observable API for Quasar channels.

Main Classes:

• NewFiberScheduler
• ChannelObservable
• BlockingObservable

Binaries

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

Example for Maven:

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

Usage

As always when using Quasar, the java agent has to be started by adding the following JVM option:

-javaagent:path-to-quasar-jar.jar

Alternatively, you can use AOT instrumentation (see the Quasar documentation).

Or, if you're running in Tomcat, you can use the Quasar class loader (see the Comsat documentation).

Observer, Function or Action method implementations can call fiber-blocking operations when using the NewFiberScheduler if the method is annotated with @Suspendable. (rx-core Observers, Functions or Actions that manipulate, transform or delegate to other Observers, Functions or Actions are automatically instrumented).