Stream an existing run

const response = await fetch(`https://api.pre.dev/browser-agent/${batchId}/stream`, {
  headers: { Authorization: `Bearer ${process.env.PREDEV_API_KEY}` },
});
if (!response.ok || !response.body) throw new Error(`Stream failed: HTTP ${response.status}`);

const reader = response.body.pipeThrough(new TextDecoderStream()).getReader();
let buffer = '';
let finished = false;
while (!finished) {
  const { value, done } = await reader.read();
  if (done) break;
  buffer += value;
  let boundary;
  while (!finished && (boundary = buffer.indexOf('\n\n')) !== -1) {
    const frame = buffer.slice(0, boundary);
    buffer = buffer.slice(boundary + 2);
    const event = frame.match(/^event: (.+)$/m)?.[1];
    const data = frame.match(/^data: (.*)$/m)?.[1];
    if (!event || data === undefined) continue; // keepalive comment
    if (event === 'error') throw new Error(JSON.parse(data).error);
    if (event === 'done') finished = true;
    console.log(event, JSON.parse(data));
  }
}
// After done (or an interrupted stream), fetch GET /browser-agent/{id} for the final result.

import json
import os
import requests

with requests.get(
    f"https://api.pre.dev/browser-agent/{batch_id}/stream",
    headers={"Authorization": f"Bearer {os.environ['PREDEV_API_KEY']}"},
    stream=True,
    timeout=(10, 120),
) as response:
    response.raise_for_status()
    event = None
    for line in response.iter_lines(decode_unicode=True):
        if line.startswith("event: "):
            event = line[len("event: "):]
        elif line.startswith("data: ") and event:
            data = json.loads(line[len("data: "):])
            if event == "error":
                raise RuntimeError(data.get("error"))
            print(event, data)
            if event == "done":
                break
# After done (or an interrupted stream), fetch GET /browser-agent/{id} for the final result.