(headers http.Header, err error)
| 1697 | } |
| 1698 | |
| 1699 | func streamErrorResult(headers http.Header, err error) *cliproxyexecutor.StreamResult { |
| 1700 | ch := make(chan cliproxyexecutor.StreamChunk, 1) |
| 1701 | ch <- cliproxyexecutor.StreamChunk{Err: err} |
| 1702 | close(ch) |
| 1703 | return &cliproxyexecutor.StreamResult{ |
| 1704 | Headers: cloneHTTPHeader(headers), |
| 1705 | Chunks: ch, |
| 1706 | } |
| 1707 | } |
| 1708 | |
| 1709 | func readStreamBootstrap(ctx context.Context, ch <-chan cliproxyexecutor.StreamChunk) ([]cliproxyexecutor.StreamChunk, bool, error) { |
| 1710 | if ch == nil { |
no test coverage detected