Function iterSSEEvents

packages/client-common/src/sse.ts:291–301

(
  stream: ReadableStream<Uint8Array> | AsyncIterable<Uint8Array>,
)

 * ```
 */
export async function* iterSSEEvents(
  stream: ReadableStream<Uint8Array> | AsyncIterable<Uint8Array>,
): AsyncGenerator<ServerSentEvent> {
  const decoder = new SSEDecoder();
  for await (const line of iterLines(stream)) {
    const event = decoder.decode(line);
    if (event !== null) {
      yield event;
    }
  }
}