Streaming

curl -N https://api.tessen.ai/v1/chat/completions \  -H "Authorization: Bearer $TESSEN_API_KEY" \  -H "Content-Type: application/json" \  -d '{    "model": "z1",    "stream": true,    "max_tokens": 256,    "messages": [{"role": "user", "content": "Say hello in five words."}]  }'

import jsonimport osimport requests with requests.post(    "https://api.tessen.ai/v1/chat/completions",    headers={"Authorization": f"Bearer {os.environ['TESSEN_API_KEY']}"},    json={        "model": "z1",        "stream": True,        "max_tokens": 256,        "messages": [{"role": "user", "content": "Say hello in five words."}],    },    stream=True,    timeout=120,) as response:    response.raise_for_status()    for line in response.iter_lines(decode_unicode=True):        if not line.startswith("data: "):            continue        data = line[len("data: "):]        if data == "[DONE]":            break        frame = json.loads(data)        if "error" in frame:  # a refusal arrives as a frame inside a 200 stream            raise RuntimeError(frame["error"]["message"])        if frame["choices"]:            print(frame["choices"][0]["delta"].get("content", ""), end="", flush=True)        else:            print()            print(frame["usage"])

const response = await fetch("https://api.tessen.ai/v1/chat/completions", {  method: "POST",  headers: { Authorization: `Bearer ${process.env.TESSEN_API_KEY}`, "Content-Type": "application/json" },  body: JSON.stringify({    model: "z1",    stream: true,    max_tokens: 256,    messages: [{ role: "user", content: "Say hello in five words." }],  }),});if (!response.ok) throw new Error(`HTTP ${response.status}: ${await response.text()}`); const decoder = new TextDecoder();let buffer = "";for await (const chunk of response.body) {  buffer += decoder.decode(chunk, { stream: true });  const lines = buffer.split("\n");  buffer = lines.pop();  for (const line of lines) {    if (!line.startsWith("data: ")) continue;    const data = line.slice("data: ".length);    if (data === "[DONE]") continue;    const frame = JSON.parse(data);    if (frame.error) throw new Error(frame.error.message); // a refusal arrives as a frame inside a 200 stream    if (frame.choices.length) process.stdout.write(frame.choices[0].delta.content ?? "");    else console.log("\n", frame.usage);  }}