durable-streaming

Overview ¶

This sample demonstrates durable streaming, which allows clients to reconnect to in-progress or completed streams using a stream ID.

Start the server:

go run .

Test streaming (get a stream ID back in X-Genkit-Stream-Id header):

curl -N -i -H "Accept: text/event-stream" \
     -d '{"data": 5}' \
     http://localhost:8080/countdown

Subscribe to an existing stream using the stream ID from the previous response:

curl -N -H "Accept: text/event-stream" \
     -H "X-Genkit-Stream-Id: <stream-id-from-above>" \
     -d '{"data": 5}' \
     http://localhost:8080/countdown

The subscription will replay any buffered chunks and then continue with live updates. If the stream has already completed, all chunks plus the final result are returned.