()
| 323 | request.signal.addEventListener('abort', abortListener, { once: true }) |
| 324 | |
| 325 | const flushEvents = async () => { |
| 326 | const events = await readEvents(streamId, cursor) |
| 327 | if (events.length > 0) { |
| 328 | logger.debug('[Resume] Flushing events', { |
| 329 | streamId, |
| 330 | afterCursor: cursor, |
| 331 | eventCount: events.length, |
| 332 | }) |
| 333 | } |
| 334 | for (const envelope of events) { |
| 335 | if (!enqueueEvent(envelope)) { |
| 336 | break |
| 337 | } |
| 338 | totalEventsFlushed += 1 |
| 339 | cursor = envelope.stream.cursor ?? String(envelope.seq) |
| 340 | currentRequestId = extractEnvelopeRequestId(envelope) || currentRequestId |
| 341 | if (envelope.type === MothershipStreamV1EventType.complete) { |
| 342 | sawTerminalEvent = true |
| 343 | } |
| 344 | } |
| 345 | } |
| 346 | |
| 347 | const emitTerminalIfMissing = ( |
| 348 | status: MothershipStreamV1CompletionStatus, |
no test coverage detected