Drops consecutively repeated values from a Flyd stream - View it on GitHub