We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7a026f2 commit 171a01fCopy full SHA for 171a01f
1 file changed
src/mcp/server/streamable_http.py
@@ -904,7 +904,7 @@ async def send_event(event_message: EventMessage) -> None:
904
stream_id = await event_store.replay_events_after(last_event_id, send_event)
905
906
# If stream ID not in mapping, create it
907
- if stream_id and stream_id not in self._request_streams:
+ if stream_id and stream_id not in self._request_streams: # pragma: no branch
908
# Register SSE writer so close_sse_stream() can close it
909
self._sse_stream_writers[stream_id] = sse_stream_writer
910
0 commit comments