Upgrade RxJava v0.14.9
Return to using Schedulers.newThread() for consumer