SSE streaming

for await (const event of nika.jobs.stream(job_id)) {
  switch (event.type) {
    case 'task_start':
      ui.start(event.task_id, event.verb)
      break
    case 'task_complete':
      ui.complete(event.task_id, event.duration_ms)
      break
    case 'artifact_written':
      ui.addArtifact(event.path, event.size)
      break
  }
}

const events = nika.jobs.stream(job_id, {
  idleTimeout: 120_000,
  maxReconnects: 5,
  reconnectDelay: 2_000,
  signal: request.signal,
})