Streaming

const stream = await assistant.stream({
  prompt: "Draft an outline for an AI Kit guide.",
  temperature: 0.5,
});

for await (const chunk of stream.textStream) {
  process.stdout.write(chunk);
}

const finalText = await stream.text;
console.log("\n---\n", finalText);

const streamedChat = await assistant.stream({
  messages: [
    { role: "user", content: "Describe the lifecycle of an AI Kit agent." },
  ],
});

for await (const delta of streamedChat.textStream) {
  process.stdout.write(delta);
}

const streamWithSchema = await assistant.stream({
  prompt: "Provide a structured test profile.",
  structuredOutput: personSpec,
});

let lastPartial;
for await (const partial of streamWithSchema.experimental_partialOutputStream) {
  lastPartial = partial;
  console.log("partial", partial);
}

const parsedOutput = await personSpec.parseOutput(
  { text: await streamWithSchema.text },
  {
    response: await streamWithSchema.response,
    usage: await streamWithSchema.usage,
    finishReason: await streamWithSchema.finishReason,
  },
);

console.log({ lastPartial, parsedOutput });