我有一个来自 chatGPT 的可读流，我试图使用 asyncIterator 对其进行断言，然后读取这些值并对其进行断言。jest 测试运行正常，但我的逻辑中有一个错误，导致每次迭代后无法解析。
我遗漏了什么？
谢谢 @隐藏人名
var util = require("util");describe("stream", () => { it("should work", async () => { let i = -1; const completionStream: ChatCompletionStreamParams = { toReadableStream: () => { const mockReadable = { async *[Symbol.asyncIterator]() { const encoder = new util.TextEncoder("utf-8"); yield encoder.encode( JSON.stringify({ id: "1", object: "text", created: 1629159835, model: "gpt4", choices: [ { index: 0, delta: { content: "Hello" }, finish_reason: null, }, ], }) ).buffer; yield encoder.encode( JSON.stringify({ id: "1", object: "text", created: 1629159835, model: "gpt4", choices: [ { index: 0, delta: { content: "there" }, finish_reason: null, }, ], }) ).buffer; yield null; }, getReader: () => { return { read: async () => { const result = await mockReadable[ Symbol.asyncIterator ]().next(); i++; if (i >= 2) { return Promise.resolve({ done: true, value: null }); } return Promise.resolve({ done: false, value: result?.value }); }, }; }, }; return mockReadable; }, }; const readable = completionStream.toReadableStream().getReader(); while (true) { const { done, value } = await readable.read(); expect(done).toBe(false); // assert here } });});回答：
你在 getReader 的 mockReadable[Symbol.asyncIterator]() 部分犯了一个错误。每当你调用 readable.read() 时，它都会被调用，这会从头开始创建一个新的 async 迭代器，因此它会一直产生 “Hello”，永远不会到达 “there”。
你需要保存迭代器并重复使用它。
getReader: () => { const iterator = mockReadable[Symbol.asyncIterator](); return { read: async () => { const result = await iterator.next(); return result; } // 实际上你可以直接将 `iterator.next` 重新暴露为 `read`，如 // read: iterator.next.bind(iterator), };}