code: func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
  	stream, err := c.conn.CreateStream(headers, nil, false)
  	if err != nil {
  		return nil, err
  	}
  	if err = stream.WaitTimeout(createStreamResponseTimeout); err != nil {
  		return nil, err
  	}
  
  	c.registerStream(stream)
  	return stream, nil
  }
docs: // CreateStream creates a new stream with the specified headers and registers
  // it with the connection.