File tree Expand file tree Collapse file tree 1 file changed +8
-7
lines changed
framework/fel/java/plugins/tool-mcp-server Expand file tree Collapse file tree 1 file changed +8
-7
lines changed Original file line number Diff line number Diff line change @@ -195,13 +195,14 @@ sseEmitter.complete();
195195``` java
196196// 使用 Choir 和 Emitter 实现 SSE
197197Choir . < TextEvent > create(emitter - > {
198- // 创建 TextEvent 并发送
199- TextEvent textEvent = TextEvent . custom()
200- .id(sessionId)
201- .event(Event . MESSAGE. code())
202- .data(jsonText)
203- .build();
204- emitter. emit(textEvent);
198+ // 创建sessionTransport类,用于调用emitter发送消息
199+ FitStreamableMcpSessionTransport sessionTransport =
200+ new FitStreamableMcpSessionTransport (sessionId, emitter, response);
201+
202+ // session的逻辑是SDK原有的,里面会调用sessionTransport发送事件流
203+ session. responseStream(jsonrpcRequest, sessionTransport)
204+ .contextWrite(ctx - > ctx. put(McpTransportContext . KEY , transportContext))
205+ .block();
205206
206207 // 监听 Emitter 的生命周期
207208 emitter. observe(new Emitter .Observer<TextEvent > () {
You can’t perform that action at this time.
0 commit comments