Implements Kata-RX-Consensus with Netflix RXJava