public function readSync()
    {
        $this->ThrowOnConnectionInvalid();
        $this->loop->removeReadStream($this->connection);
        $this->readToBuffer();
        $this->attachReadStream();
    }