File tree Expand file tree Collapse file tree 1 file changed +1
-43
lines changed Expand file tree Collapse file tree 1 file changed +1
-43
lines changed Original file line number Diff line number Diff line change @@ -165,46 +165,6 @@ export const proxyServer = async ({
165
165
} ) ;
166
166
} ;
167
167
168
- /**
169
- * @author https://dev.classmethod.jp/articles/mcp-sse/
170
- */
171
- const startSending = async ( transport : SSEServerTransport ) => {
172
- try {
173
- let messageCount = 0 ;
174
- const interval = setInterval ( async ( ) => {
175
- messageCount ++ ;
176
-
177
- const message = `Message ${ messageCount } at ${ new Date ( ) . toISOString ( ) } ` ;
178
-
179
- try {
180
- await transport . send ( {
181
- jsonrpc : "2.0" ,
182
- method : "sse/message" ,
183
- params : { data : message } ,
184
- } ) ;
185
-
186
- console . log ( `Sent: ${ message } ` ) ;
187
-
188
- if ( messageCount === 10 ) {
189
- clearInterval ( interval ) ;
190
-
191
- await transport . send ( {
192
- jsonrpc : "2.0" ,
193
- method : "sse/complete" ,
194
- params : { message : "Stream completed" } ,
195
- } ) ;
196
- console . log ( "Stream completed" ) ;
197
- }
198
- } catch ( error ) {
199
- console . error ( "Error sending message:" , error ) ;
200
- clearInterval ( interval ) ;
201
- }
202
- } , 1000 ) ;
203
- } catch ( error ) {
204
- console . error ( "Error in startSending:" , error ) ;
205
- }
206
- } ;
207
-
208
168
export type SSEServer = {
209
169
close : ( ) => Promise < void > ;
210
170
} ;
@@ -263,9 +223,7 @@ export const startSSEServer = async <T extends ServerLike>({
263
223
264
224
onClose ?.( server ) ;
265
225
} ) ;
266
-
267
- startSending ( transport ) ;
268
-
226
+
269
227
return ;
270
228
}
271
229
You can’t perform that action at this time.
0 commit comments