Skip to content

Commit 55f084d

Browse files
RobertCraigiestainless-app[bot]
authored andcommitted
chore: fix streaming
1 parent b08a846 commit 55f084d

File tree

1 file changed

+2
-12
lines changed

1 file changed

+2
-12
lines changed

Diff for: src/streaming.ts

+2-12
Original file line numberDiff line numberDiff line change
@@ -52,22 +52,12 @@ export class Stream<Item> implements AsyncIterable<Item> {
5252
if (data && data.error) {
5353
throw new APIError(undefined, data.error, undefined, undefined);
5454
}
55-
56-
yield data;
57-
} else {
58-
let data;
59-
try {
60-
data = JSON.parse(sse.data);
61-
} catch (e) {
62-
console.error(`Could not parse message into JSON:`, sse.data);
63-
console.error(`From chunk:`, sse.raw);
64-
throw e;
65-
}
6655
// TODO: Is this where the error should be thrown?
6756
if (sse.event == 'error') {
6857
throw new APIError(undefined, data.error, data.message, undefined);
6958
}
70-
yield { event: sse.event, data: data } as any;
59+
60+
yield data;
7161
}
7262
}
7363
done = true;

0 commit comments

Comments
 (0)