(ch <-chan CopilotWebSocketMessage)
| 208 | } |
| 209 | |
| 210 | func drainBody(ch <-chan CopilotWebSocketMessage) []byte { |
| 211 | var buf bytes.Buffer |
| 212 | for frame := range ch { |
| 213 | buf.Write(frame.Data) |
| 214 | } |
| 215 | return buf.Bytes() |
| 216 | } |
| 217 | |
| 218 | func streamResponseToSink(resp *http.Response, sink *responseSink) error { |
| 219 | if err := sink.start(resp.StatusCode, statusText(resp), cloneHeader(resp.Header)); err != nil { |
no test coverage detected
searching dependent graphs…