SSE streaming

for await (const event of run.events({ bufferSize: 64 })) {
  render(event)
  if (event.sequence !== undefined) {
    await persistSequence(run.id, event.sequence)
  }
}

NikaRunEvent is open to additive fields and event kinds. Render only what the application understands, preserve sequence when it is present, and use run.result() for terminal truth. The untouched protocol frame is on event.raw. Each subscriber has a bounded queue. If a consumer falls behind, the SDK throws NikaEventBufferOverflowError rather than silently losing evidence.

Stop one view

const controller = new AbortController()

for await (const event of run.events({
  signal: controller.signal,
})) {
  render(event)
}

The signal stops only this subscriber. Call run.cancel() to ask the server to cancel engine work.

Resume from application state

const recovered = await nika.attachRun(jobId, {
  lastEventId: lastCommittedSequence,
})

The HTTP adapter uses the persisted cursor for SSE continuity. The application owns when a sequence is durable. A paused settlement closes the current stream and resolves run.result() with that leg’s result and evidence. The durable job can later resume under engine authority; a new attachment can observe that later leg. Replaying or attaching after the settlement event has already been consumed still reads the full stored settlement. Stopping a stream or attaching to a job never answers a human gate.

Which published source this page describes

Jobs

Own identity and recovery around the stream.

Runtime events

Build a tolerant presentation reducer.

Overview

Start

Project

Local API

Runtime

Remote API

Operations

Reference

SSE streaming

Stop one view

Resume from application state

Jobs

Runtime events

​Stop one view

​Resume from application state

Jobs

Runtime events

Stop one view

Resume from application state