Update RxJava usage in blocking implementation.