Replacing rxscala with akka-stream.