| 186 | }; |
| 187 | |
| 188 | const sendMessageStop = (stopReason: string) => { |
| 189 | if (streamClosed) return; |
| 190 | streamClosed = true; |
| 191 | safeEnqueue(encoder.encode(`event: message_delta\ndata: ${JSON.stringify({ |
| 192 | type: "message_delta", |
| 193 | delta: { stop_reason: stopReason, stop_sequence: null }, |
| 194 | usage: { output_tokens: 1 }, |
| 195 | })}\n\n`)); |
| 196 | safeEnqueue(encoder.encode(`event: message_stop\ndata: ${JSON.stringify({ |
| 197 | type: "message_stop", |
| 198 | })}\n\n`)); |
| 199 | controller.close(); |
| 200 | }; |
| 201 | |
| 202 | const parser = createParser((event) => { |
| 203 | try { |