We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b08a846 commit 55f084dCopy full SHA for 55f084d
src/streaming.ts
@@ -52,22 +52,12 @@ export class Stream<Item> implements AsyncIterable<Item> {
52
if (data && data.error) {
53
throw new APIError(undefined, data.error, undefined, undefined);
54
}
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
- }
66
// TODO: Is this where the error should be thrown?
67
if (sse.event == 'error') {
68
throw new APIError(undefined, data.error, data.message, undefined);
69
70
- yield { event: sse.event, data: data } as any;
+
+ yield data;
71
72
73
done = true;
0 commit comments