public function reduce(callable $accumulator, $seed = null): Observable
    {
        return $this->lift(function () use ($accumulator, $seed) {
            return new ReduceOperator($accumulator, $seed);
        });
    }