stream property

Stream<T> stream

Implementation

Stream<T> get stream {
  return _stream.where(
    (event) {
      final newHashCode = ComparableWrapper(event).hashCode;
      if ((newHashCode == lastKnownHashcode) && distinctValues) {
        return false;
      }
      lastKnownHashcode = newHashCode;
      return true;
    },
  );
}