diff --git a/src/core/streaming.ts b/src/core/streaming.ts index d9cad674..fcc30891 100644 --- a/src/core/streaming.ts +++ b/src/core/streaming.ts @@ -66,6 +66,11 @@ export class Stream implements AsyncIterable { sse.event === 'content_block_delta' || sse.event === 'content_block_stop' ) { + // skip streaming events with no data + if(sse.data == null) { + continue; + } + try { yield JSON.parse(sse.data); } catch (e) {