Method ensureHeaders

coderd/aibridged/transport.go:197–201

ensureHeaders closes gotHeaders if it has not already been closed, with the current status. Used to unblock RoundTrip on handler return-without-write.

()

// ensureHeaders closes gotHeaders if it has not already been closed, with the
// current status. Used to unblock RoundTrip on handler return-without-write.
func (w *pipeResponseWriter) ensureHeaders() {
	w.once.Do(func() {
		close(w.gotHeaders)
	})
}

var (
	_ http.ResponseWriter = (*pipeResponseWriter)(nil)