RxJava types that are both an Observable and a Consumer. - View it on GitHub