Sync/DiffProvider/Binlog/BinlogParser.php
public function rewind()
    {
        $this->key = 0;

        if ($this->pipe) {
            pclose($this->pipe);
        }

        $this->pipe = null;
        $this->lastLine = null;
        $this->lastLineType = null;
        $this->lastDateTime = null;
        $this->lastLogPosition = null;

        if ($this->status === self::STATE_CLEAN) {
            if (!empty($this->buffer)) {
                $this->status = self::STATE_DIRTY;
            } else {
                $this->nextBufferLine();
            }
        }
    }
public function rewind()
    {
        $this->key = 0;

        if ($this->pipe) {
            pclose($this->pipe);
        }

        $this->pipe = null;
        $this->lastLine = null;
        $this->lastLineType = null;
        $this->lastDateTime = null;
        $this->lastLogPosition = null;

        if ($this->status === self::STATE_CLEAN) {
            if (!empty($this->buffer)) {
                $this->status = self::STATE_DIRTY;
            } else {
                $this->nextBufferLine();
            }
        }
    }
{@inheritdoc}