Skip to content

Commit 9515f60

Browse files
RobertCraigiestainless-app[bot]
authored andcommitted
chore(bedrock): use chunk for internal SSE parsing instead of completion (#472)
1 parent 8274f4b commit 9515f60

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

packages/bedrock-sdk/src/streaming.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ export class Stream<Item> extends CoreStream<Item> {
4747
for await (const event of eventStream) {
4848
if (event.chunk && event.chunk.bytes) {
4949
const s = toUtf8(event.chunk.bytes);
50-
yield { event: 'completion', data: s, raw: [] };
50+
yield { event: 'chunk', data: s, raw: [] };
5151
} else if (event.internalServerException) {
5252
yield { event: 'error', data: 'InternalServerException', raw: [] };
5353
} else if (event.modelStreamErrorException) {
@@ -69,7 +69,7 @@ export class Stream<Item> extends CoreStream<Item> {
6969
let done = false;
7070
try {
7171
for await (const sse of iterMessages()) {
72-
if (sse.event === 'completion') {
72+
if (sse.event === 'chunk') {
7373
try {
7474
yield JSON.parse(sse.data);
7575
} catch (e) {

0 commit comments

Comments
 (0)