Basically, this project has two modules:
RxMQTT API is a set of interfaces that was built on top of RxJava for composing asynchronous and event-based programs by using observable sequences. These interfaces define a higher abstraction for implementations.
RxMQTT Paho is the implementation of RxMQTT API that was built on top of Eclipse Paho Java Client framework to handle MQTT messages.
For more informations, see the Wiki Page.
Maven:
<dependency>
<groupId>br.com.thiaguten</groupId>
<artifactId>rx-mqtt-paho</artifactId>
<version>${version}</version>
</dependency>
Gradle:
compile "br.com.thiaguten:rx-mqtt-paho:$version"