Documentation / @agentick/server / createSSEWriter

Function: createSSEWriter()

createSSEWriter(stream, options?): SSEWriter

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

Create an SSE writer for a response stream.

Works with any writable stream that has write() and end() methods (Node.js response, Express response, etc.).

Parameters

stream

end

() => void

write

(data) => void

options?

SSEWriterOptions = {}

Returns

SSEWriter

Example

// Express
app.get('/events', (req, res) => {
  setSSEHeaders(res);
  const writer = createSSEWriter(res);

  // Write events
  writer.writeEvent({
    channel: 'session:events',
    type: 'content_delta',
    payload: { delta: 'Hello' },
  });

  // Close when done
  writer.close();
});