DistinctUniqueExtension<T> extension

Extends the Stream class with the ability to skip items that have previously been emitted.

on
  • Stream<T>

Methods

distinctUnique({bool equals(T e1, T e2), int hashCode(T e)}) → Stream<T>
WARNING: More commonly known as distinct in other Rx implementations. Creates a Stream where data events are skipped if they have already been emitted before. [...]