fix connection leak when start timeout

leavez · leavez · commit 71d1d0d6b212 · 2025-04-06T10:41:02.000+08:00
diff --git a/client/transport/sse.go b/client/transport/sse.go
@@ -114,6 +114,7 @@ func (c *SSE) Start(ctx context.Context) error {
 	case <-ctx.Done():
 		return fmt.Errorf("context cancelled while waiting for endpoint")
 	case <-time.After(30 * time.Second): // Add a timeout
+		cancel()
 		return fmt.Errorf("timeout waiting for endpoint")
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -114,6 +114,7 @@ func (c *SSE) Start(ctx context.Context) error {`
`114`	`114`	`case <-ctx.Done():`
`115`	`115`	`return fmt.Errorf("context cancelled while waiting for endpoint")`
`116`	`116`	`case <-time.After(30 * time.Second): // Add a timeout`
	`117`	`+ cancel()`
`117`	`118`	`return fmt.Errorf("timeout waiting for endpoint")`
`118`	`119`	`}`
`119`	`120`