public function connect(ConnectionContext $ctx, string $header = ''): Promise
    {
        $this->in_seq_no = -1;
        $this->out_seq_no = -1;
        $this->stream = new HashedBufferedStream();
        $this->stream->setExtra('crc32b_rev');

        return $this->stream->connect($ctx, $header);
    }