Made RxJava lambda compliant