From ccaa7e17be8a8dd3d7763b5d0e5a3d09df90287a Mon Sep 17 00:00:00 2001 From: Nicolas Meienberger Date: Thu, 16 Apr 2026 21:42:42 +0200 Subject: [PATCH] chore: update api-client --- app/client/api-client/core/serverSentEvents.gen.ts | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/app/client/api-client/core/serverSentEvents.gen.ts b/app/client/api-client/core/serverSentEvents.gen.ts index 724bd1a0..1a2bf004 100644 --- a/app/client/api-client/core/serverSentEvents.gen.ts +++ b/app/client/api-client/core/serverSentEvents.gen.ts @@ -80,7 +80,7 @@ export type ServerSentEventsResult; }; -export const createSseClient = ({ +export function createSseClient({ onRequest, onSseError, onSseEvent, @@ -92,7 +92,7 @@ export const createSseClient = ({ sseSleepFn, url, ...options -}: ServerSentEventsOptions): ServerSentEventsResult => { +}: ServerSentEventsOptions): ServerSentEventsResult { let lastEventId: string | undefined; const sleep = sseSleepFn ?? ((ms: number) => new Promise((resolve) => setTimeout(resolve, ms))); @@ -156,8 +156,7 @@ export const createSseClient = ({ const { done, value } = await reader.read(); if (done) break; buffer += value; - // Normalize line endings: CRLF -> LF, then CR -> LF - buffer = buffer.replace(/\r\n/g, '\n').replace(/\r/g, '\n'); + buffer = buffer.replace(/\r\n?/g, '\n'); // normalize line endings const chunks = buffer.split('\n\n'); buffer = chunks.pop() ?? ''; @@ -241,4 +240,4 @@ export const createSseClient = ({ const stream = createStream(); return { stream }; -}; +}