Function jsonSSE

jsonSSE<T = unknown>(
    source: AsyncIterable<SSEEvent>,
    options?: {
        onError?: (err: unknown, event: SSEEvent) => void;
        reviver?: (this: any, key: string, value: any) => any;
    },
): AsyncGenerator<JSONSSEEvent<T>>
Higher-order wrapper that parses SSE data as JSON.

Non-JSON events are silently skipped (optional onError callback).
Type Parameters
- T = unknown
Parameters
- source: AsyncIterable<SSEEvent>
  AsyncIterable of SSEEvent (e.g., from SSEClient)
- options: {
  onError?: (err: unknown, event: SSEEvent) => void;
  reviver?: (this: any, key: string, value: any) => any;
  } = {}
  Options with optional onError callback and reviver
  - OptionalonError?: (err: unknown, event: SSEEvent) => void
    Called when JSON.parse fails on an event's data. If omitted, errors are silently ignored.
  - Optionalreviver?: (this: any, key: string, value: any) => any
Returns AsyncGenerator<JSONSSEEvent<T>>
Yields
A typed object with event, data, and id fields.
Example
```
for await (const { event, data } of jsonSSE<T>(client, {
  onError: (err, evt) => console.warn("Parse error:", evt.data),
})) {
  console.log(event, data);
}
```
- Defined in src/sse.ts:681