|
@@ -347,12 +347,10 @@ func ParseStreamResponse(response *http.Response) (contentChan chan string, errC
|
|
|
closeChan = make(chan struct{})
|
|
|
closeLlmChan = make(chan bool, 1)
|
|
|
go func() {
|
|
|
- defer func() {
|
|
|
- close(contentChan)
|
|
|
- close(errChan)
|
|
|
- close(closeChan)
|
|
|
- close(closeLlmChan)
|
|
|
- }()
|
|
|
+ defer close(contentChan)
|
|
|
+ defer close(errChan)
|
|
|
+ defer close(closeChan)
|
|
|
+ defer close(closeLlmChan)
|
|
|
|
|
|
scanner := bufio.NewScanner(response.Body)
|
|
|
scanner.Split(bufio.ScanLines)
|