> Discover all available pages from the documentation index: https://mastra.zisheng.pro/llms.txt

# Run.observeStream()

`.observeStream()` 方法会为当前正在运行的 Workflow 打开一个新的 `ReadableStream`。如果原始 Stream 已不可用，你仍可借此观察事件 Stream。

## 用法示例

```typescript
const run = await workflow.createRun()

run.stream({
  inputData: {
    value: 'initial data',
  },
})

const stream = await run.observeStream()

for await (const chunk of stream) {
  console.log(chunk)
}
```

## 返回值

`ReadableStream<ChunkType>`

## Stream 事件

Stream 会在 Workflow 执行期间发出不同类型的事件。每个事件都有一个 `type` 字段，以及一个包含相关数据的 `payload`：

- **`workflow-start`**：Workflow 开始执行
- **`workflow-step-start`**：步骤开始执行
- **`workflow-step-output`**：步骤的自定义输出
- **`workflow-step-result`**：步骤完成并产生结果
- **`workflow-finish`**：Workflow 执行完成，并附带用量统计信息。对于成功的运行，`payload.finalWorkflowResult` 包含 Workflow 的最终结果

## 相关内容

- [Workflow 概览](https://mastra.zisheng.pro/docs/workflows/overview)
- [Workflow.createRun()](https://mastra.zisheng.pro/reference/workflows/workflow-methods/create-run)
- [Run.stream()](https://mastra.zisheng.pro/reference/streaming/workflows/stream)
- [Run.resumeStream()](https://mastra.zisheng.pro/reference/streaming/workflows/resumeStream)