Add distinctConsecutive{,By} to process1

This one adds `distinctConsecutive` and `distinctConsecutiveBy(f)` to `process1` which remove consecutive duplicates from the input such that the first element of those duplicates is emitted.

RxJava has the same operation and they call it [distinctUntilChanged](https://github.com/ReactiveX/RxJava/wiki/Filtering-Observables#distinctuntilchanged). Suggestions for better names are welcome!