Code updated to work with RxJava 0.19