Skip to content

Commit 0309bb8

Browse files
committed
fix: remove arbitrary timeout context for request processing on SSE stream
1 parent 68e8505 commit 0309bb8

File tree

1 file changed

+0
-7
lines changed

1 file changed

+0
-7
lines changed

client/transport/streamable_http.go

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -406,13 +406,6 @@ func (c *StreamableHTTP) handleSSEResponse(ctx context.Context, reader io.ReadCl
406406
// Create a channel for this specific request
407407
responseChan := make(chan *JSONRPCResponse, 1)
408408

409-
// Add timeout context for request processing if not already set
410-
if deadline, ok := ctx.Deadline(); !ok || time.Until(deadline) > 30*time.Second {
411-
var cancel context.CancelFunc
412-
ctx, cancel = context.WithTimeout(ctx, 30*time.Second)
413-
defer cancel()
414-
}
415-
416409
ctx, cancel := context.WithCancel(ctx)
417410
defer cancel()
418411

0 commit comments

Comments
 (0)