Documentation / @agentick/server / streamToSSE

Function: streamToSSE()

streamToSSE<T>(stream, events, channel, options?): Promise<void>

Defined in: server/src/sse.ts:112

Stream an async iterable to SSE.

Type Parameters

T

T

Parameters

stream

end

() => void

write

(data) => void

events

AsyncIterable<T>

channel

string

options?

SSEWriterOptions = {}

Returns

Promise<void>

Example

app.get('/sessions/:id/stream', async (req, res) => {
  setSSEHeaders(res);

  const stream = sessionHandler.stream(req.params.id, {});
  await streamToSSE(res, stream, 'session:events');
});