Skip to content

Commit 12de2ce

Browse files
fix: capture SSE retry field via onRetry callback
The eventsource-parser library delivers retry through onRetry callback, not as a property on EventSourceMessage objects.
1 parent de5ebab commit 12de2ce

File tree

1 file changed

+6
-7
lines changed

1 file changed

+6
-7
lines changed

src/scenarios/server/sse-polling.ts

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,12 @@ export class ServerSSEPollingScenario implements ClientScenario {
9898

9999
const reader = response.body
100100
.pipeThrough(new TextDecoderStream())
101-
.pipeThrough(new EventSourceParserStream())
101+
.pipeThrough(new EventSourceParserStream({
102+
onRetry: (retryMs: number) => {
103+
hasRetryField = true;
104+
retryValue = retryMs;
105+
}
106+
}))
102107
.getReader();
103108

104109
// Read events with timeout
@@ -137,12 +142,6 @@ export class ServerSSEPollingScenario implements ClientScenario {
137142
}
138143
}
139144
}
140-
141-
// Check for retry field
142-
if (event.retry !== undefined) {
143-
hasRetryField = true;
144-
retryValue = event.retry;
145-
}
146145
}
147146
} finally {
148147
clearTimeout(timeout);

0 commit comments

Comments
 (0)