From b873e385905924dbdb7e4c974d8b2f4fa94ffcb3 Mon Sep 17 00:00:00 2001 From: Sree Narayanan Date: Fri, 2 Oct 2026 12:44:25 +0000 Subject: [PATCH] docs(agents): remove unused agents/examples/agent Amp-Thread-ID: https://ampcode.com/threads/T-af28ce42-6c01-4358-8608-8c5c7f7e3150 Co-authored-by: Amp --- agents/examples/agent/client.ts | 8 -------- agents/examples/agent/index.ts | 28 ---------------------------- 2 files changed, 36 deletions(-) delete mode 100644 agents/examples/agent/client.ts delete mode 100644 agents/examples/agent/index.ts diff --git a/agents/examples/agent/client.ts b/agents/examples/agent/client.ts deleted file mode 100644 index 4eb8f47e..00000000 --- a/agents/examples/agent/client.ts +++ /dev/null @@ -1,8 +0,0 @@ -import { createClient } from "rivetkit/client"; -import type { registry } from "./index"; - -const client = createClient("http://localhost:6420"); - -const agent = client.agent.getOrCreate(["agent-123"]).connect(); -agent.on("token", (delta: string) => process.stdout.write(delta)); -await agent.queue.send("message", { text: "hello!" }); diff --git a/agents/examples/agent/index.ts b/agents/examples/agent/index.ts deleted file mode 100644 index 7e87bf06..00000000 --- a/agents/examples/agent/index.ts +++ /dev/null @@ -1,28 +0,0 @@ -import { actor, setup } from "rivetkit"; -import { streamText, type ModelMessage } from "ai"; -import { openai } from "@ai-sdk/openai"; - -// One actor per agent: its transcript is durable state, its inbox is a queue, -// and its output streams to every connected client. -export const agent = actor({ - state: { messages: [] as ModelMessage[] }, - - run: async (c) => { - for await (const msg of c.queue.iter<{ text: string }>()) { - c.state.messages.push({ role: "user", content: msg.body.text }); - - const response = streamText({ - model: openai("gpt-5"), - messages: c.state.messages, - }); - - for await (const delta of response.textStream) { - c.broadcast("token", delta); - } - - c.state.messages.push({ role: "assistant", content: await response.text }); - } - }, -}); - -export const registry = setup({ use: { agent } });