Migrate streams to reactive-streams 0.4.M1

in other places `produceTo` was replaced with `subscribe`, perhaps here too afterwards?