public function repeat(int $count = -1): Observable
    {
        if ($count === 0) {
            return self::empty();
        }

        return $this->lift(function () use ($count) {
            return new RepeatOperator($count);
        });
    }