Merge pull request #1657 from nasonawa/mcp_streamhttp_recordparse_sse_events

added Record Parser to parse each sse event

Author: geoand

mcp/runtime/src/main/java/io/quarkiverse/langchain4j/mcp/runtime/http/QuarkusStreamableHttpMcpTransport.java

@@ -34,6 +34,7 @@
 import io.vertx.core.http.HttpClient;
 import io.vertx.core.http.HttpMethod;
 import io.vertx.core.http.RequestOptions;
+import io.vertx.core.parsetools.RecordParser;
 
 public class QuarkusStreamableHttpMcpTransport implements McpTransport {
 
@@ -143,14 +144,16 @@ private Uni<JsonNode> execute(McpClientMessage request, Long id) {
                                         this.mcpSessionId.set(mcpSessionId);
                                     }
 
+                                    RecordParser sseEventparser = RecordParser.newDelimited("\n\n", bodyBuffer -> {
+                                        String responseString = bodyBuffer.toString();
+                                        SseEvent<String> sseEvent = parseSseEvent(responseString);
+                                        sseSubscriber.accept(sseEvent);
+                                    });
+
                                     String contentType = response.result().getHeader("Content-Type");
                                     if (id != null && contentType != null && contentType.contains("text/event-stream")) {
                                         // the server has started a SSE channel
-                                        response.result().handler(bodyBuffer -> {
-                                            String responseString = bodyBuffer.toString();
-                                            SseEvent<String> sseEvent = parseSseEvent(responseString);
-                                            sseSubscriber.accept(sseEvent);
-                                        });
+                                        response.result().handler(sseEventparser);
                                     } else {
                                         // the server has sent a single regular response
                                         if (id == null) {