Migrate streams to reactive-streams 0.4.M1

Why the `equalityValue`? For one of the new spec's "subscriber based on object equality" points?