fix: handle the situation where the channel is closed (#304)

button-chen · web-flow · commit 99720bb4c451 · 2025-05-19T23:51:57.000+03:00
diff --git a/client/transport/sse.go b/client/transport/sse.go
@@ -310,8 +310,11 @@ func (c *SSE) SendRequest(
 	case <-ctx.Done():
 		deleteResponseChan()
 		return nil, ctx.Err()
-	case response := <-responseChan:
-		return response, nil
+	case response, ok := <-responseChan:
+		if ok {
+			return response, nil
+		}
+		return nil, fmt.Errorf("connection has been closed")
 	}
 }
 

Original file line number	Diff line number	Diff line change
`@@ -310,8 +310,11 @@ func (c *SSE) SendRequest(`
`310`	`310`	`case <-ctx.Done():`
`311`	`311`	`deleteResponseChan()`
`312`	`312`	`return nil, ctx.Err()`
`313`		`- case response := <-responseChan:`
`314`		`- return response, nil`
	`313`	`+ case response, ok := <-responseChan:`
	`314`	`+ if ok {`
	`315`	`+ return response, nil`
	`316`	`+ }`
	`317`	`+ return nil, fmt.Errorf("connection has been closed")`
`315`	`318`	`}`
`316`	`319`	`}`
`317`	`320`