Reactive Queue with Akka Reactive Streams: Cascade on the river