Skip to content

Commit 3a98694

Browse files
parity with ts sdk
1 parent d1ac8d6 commit 3a98694

File tree

1 file changed

+10
-9
lines changed

1 file changed

+10
-9
lines changed

src/mcp/client/streamable_http.py

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -281,15 +281,16 @@ async def _handle_post_request(self, ctx: RequestContext) -> None:
281281

282282
content_type = response.headers.get(CONTENT_TYPE, "").lower()
283283

284-
if content_type.startswith(JSON):
285-
await self._handle_json_response(response, ctx.read_stream_writer, is_initialization)
286-
elif content_type.startswith(SSE):
287-
await self._handle_sse_response(response, ctx, is_initialization)
288-
else:
289-
await self._handle_unexpected_content_type(
290-
content_type,
291-
ctx.read_stream_writer,
292-
)
284+
if isinstance(message.root, JSONRPCRequest):
285+
if content_type.startswith(JSON):
286+
await self._handle_json_response(response, ctx.read_stream_writer, is_initialization)
287+
elif content_type.startswith(SSE):
288+
await self._handle_sse_response(response, ctx, is_initialization)
289+
else:
290+
await self._handle_unexpected_content_type(
291+
content_type,
292+
ctx.read_stream_writer,
293+
)
293294

294295
async def _handle_json_response(
295296
self,

0 commit comments

Comments
 (0)