RxJava 2.0 converted to JDK 9 Flow API - View it on GitHub