Migrate streams to reactive-streams 0.4.M1

put into separate file?