Maybe it's interesting to show us an example using [Flow](http://download.java.net/java/jdk9/docs/api/java/util/concurrent/Flow.html) from Java 9.