fix: update crates/rmcp/src/transport/streamable_http_client.rs

DaleSeo · web-flow · commit a299b69fd6bf · 2026-07-06T22:22:24.000-04:00
diff --git a/crates/rmcp/src/transport/streamable_http_client.rs b/crates/rmcp/src/transport/streamable_http_client.rs
@@ -361,7 +361,7 @@ impl<C: StreamableHttpClient> StreamableHttpClientWorker<C> {
             return Ok(());
         }
 
-        let pending_ids = pending_stream_response_ids.drain().collect::<Vec<_>>();
+        let pending_ids = std::mem::take(pending_stream_response_ids);
         for id in pending_ids {
             context
                 .send_to_handler(ServerJsonRpcMessage::error(

Original file line number	Diff line number	Diff line change
`@@ -361,7 +361,7 @@ impl<C: StreamableHttpClient> StreamableHttpClientWorker<C> {`
`361`	`361`	`return Ok(());`
`362`	`362`	`}`
`363`	`363`
`364`		`- let pending_ids = pending_stream_response_ids.drain().collect::<Vec<_>>();`
	`364`	`+ let pending_ids = std::mem::take(pending_stream_response_ids);`
`365`	`365`	`for id in pending_ids {`
`366`	`366`	`context`
`367`	`367`	`.send_to_handler(ServerJsonRpcMessage::error(`