A reactive-streams.org implementation in Scala