code: func (c *connection) newSpdyStream(stream *spdystream.Stream) {
  	replySent := make(chan struct{})
  	err := c.newStreamHandler(stream, replySent)
  	rejectStream := (err != nil)
  	if rejectStream {
  		klog.Warningf("Stream rejected: %v", err)
  		stream.Reset()
  		return
  	}
  
  	c.registerStream(stream)
  	stream.SendReply(http.Header{}, rejectStream)
  	close(replySent)
  }
docs: // newSpdyStream is the internal new stream handler used by spdystream.Connection.Serve.
  // It calls connection's newStreamHandler, giving it the opportunity to accept or reject
  // the stream. If newStreamHandler returns an error, the stream is rejected. If not, the
  // stream is accepted and registered with the connection.