Migrate streams to reactive-streams 0.4.M1