rxjava-quasar
Integrates RxJava with Quasar. Includes a fiber (lightweight-thread) based scheduler, and an Observable API for Quasar channels.
Main Classes:
Binaries
Binaries and dependency information for Maven, Ivy, Gradle and others can be found at http://search.maven.org.
Example for Maven:
<dependency>
<groupId>com.netflix.rxjava</groupId>
<artifactId>rxjava-quasar</artifactId>
<version>x.y.z</version>
</dependency>
and for Ivy:
<dependency org="com.netflix.rxjava" name="rxjava-quasar" rev="x.y.z" />
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 Observer
s, Function
s or Action
s that manipulate, transform or delegate to other Observer
s, Function
s or Action
s are automatically instrumented).