Stream<T> distinct([bool Function(T previous, T next)? test]) { return test != null ? _subject.distinct(test) : _subject.distinct(); }