Merge pull request #2242 from CortexFoundation/dev

prevent hanging dispatch
CortexFoundation · Jan 7, 2025 · fb580f5 · fb580f5
2 parents e99e2e0 + c819b39
commit fb580f5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/ctxc/dispatcher.go b/ctxc/dispatcher.go
@@ -174,6 +174,8 @@ func (p *peer) dispatchResponse(res *Response, metadata func() any) error {
 				return <-res.Done // Response delivered, return any errors
 			case <-res.Req.cancel:
 				return nil // Request cancelled, silently discard response
+			case <-p.term:
+				return errDisconnected
 			}
 		}