schema/ 定义"数据长什么样"——它是全框架的通用货币。四个核心类型：

Message（schema/message.go:498）同时承载"用户输入"和"模型输出"，兼容纯文本和多模态。核心字段：

type Message struct {
    Role    RoleType   // 谁说的：System/User/Assistant/Tool
    Content string     // 纯文本内容
    // 多模态（新）：用户输入 / 模型输出 分开
    UserInputMultiContent     []MessageInputPart
    AssistantGenMultiContent  []MessageOutputPart
    // 仅 Assistant 消息：模型要发起的工具调用
    ToolCalls []ToolCall
    // 仅 Tool 消息：把工具执行结果关联回之前某次 tool_call
    ToolCallID string
    ToolName   string
    ResponseMeta      *ResponseMeta   // 元信息：FinishReason、Usage(token 数)
    ReasoningContent  string          // 推理模型的思维链
    Extra map[string]any              // 各实现自定义扩展位
}

便捷构造器：SystemMessage() / UserMessage() / AssistantMessage() / ToolMessage()（message.go:1105 起）。

RoleType 四种常量（message.go:111）：

有意思的是——Message 自己实现了 MessagesTemplate 接口（message.go:573），能当提示词模板用：

Format(ctx, vs map[string]any, formatType FormatType) ([]*Message, error)

支持三种模板语法（message.go:99）：FString（Python 风格 {name}）、GoTemplate、Jinja2。还有 MessagesPlaceholder(key)（message.go:595）——把"历史消息列表"原样插进模板某处。

大模型不是"憋完整段话再返回"，而是一个 token 一个 token 地吐（你看 ChatGPT 打字机效果就是）。Eino 用 StreamReader[T] 抽象这种"流"。

核心是一对泛型类型（schema/stream.go）：StreamWriter[T]（生产端，往里写） 和 StreamReader[T]（消费端，往外读）。用 Pipe 一次造出一对（stream.go:99）：

sr, sw := schema.Pipe[*Message](cap)   // 造一读一写，底层是带缓冲 channel

// 生产端（比如模型实现）：
sw.Send(chunk, err)   // 发一个分片（stream.go:126）；返回 closed=true 说明读端已关，可停手
sw.Close()            // 发完关闭

// 消费端（比如你的代码）：
for {
    chunk, err := sr.Recv()   // 收一个分片（stream.go:195）
    if err == io.EOF { break }  // channel 关了 → EOF，读完了
    // 用 chunk...
}
sr.Close()   // ★ 必须调一次！即使已 EOF 或提前 break

StreamReader 是单消费者的（一个流只能被读一次）。但编排时经常要"同一份输出既喂给下一个节点、又喂给回调 handler"。解决办法是 Copy(n)（stream.go:261）——扇出成 n 个独立 reader，各自都能读到全部元素：

readers := sr.Copy(2)   // 变成 2 个独立流，原 sr 作废
// readers[0] 给下一个节点，readers[1] 给回调 handler，互不影响

Day 01 讲的"Runnable 4 范式自动转换"（流↔非流），底层就靠这里——把一串消息分片拼成一条完整消息。ConcatMessages（message.go:1644）：

// 把 [北] [京] [今] [天] [晴] 这些分片 → 拼成一条完整 Message{Content: "北京今天晴"}
full, _ := schema.ConcatMessages(chunks)
// ConcatMessageStream：直接把整条流拼成一条消息（message.go:1842）
full, _ := schema.ConcatMessageStream(stream)

✋ 动手：对着真实代码读一遍

# 1. Message 结构与 Role（L02/L03）
sed -n '498,532p' schema/message.go
sed -n '111,120p' schema/message.go

# 2. Stream 的 Pipe/Send/Recv/Copy（L06/L07）
sed -n '99,140p' schema/stream.go
sed -n '261,300p' schema/stream.go

# 3. 拼接函数的注册（L08，4 范式的地基）
sed -n '40,48p' schema/message.go
grep -n "func ConcatMessages\|func ConcatMessageStream" schema/message.go