Scala Future-based implementation of Reactive Streams