distinct method

LxStream<T> distinct([
  1. bool equals(
    1. T previous,
    2. T next
    )?
])

Skips duplicate events.

Implementation

LxStream<T> distinct([bool Function(T previous, T next)? equals]) {
  return LxStream<T>(valueStream.distinct(equals));
}