public function distinctUntilChanged(callable $comparer = null): Observable
    {
        return $this->lift(function () use ($comparer) {
            return new DistinctUntilChangedOperator(null, $comparer);
        });
    }