public function bufferWithCount(int $count, int $skip = null): Observable
    {
        return $this->lift(function () use ($count, $skip) {
            return new BufferWithCountOperator($count, $skip);
        });
    }