()
| 134 | { type: 'message_stop' }, |
| 135 | ]; |
| 136 | async function* fakeStream() { |
| 137 | for (const c of chunks) { |
| 138 | yield { chunk: { bytes: Buffer.from(JSON.stringify(c)) } }; |
| 139 | } |
| 140 | } |
| 141 | proxy._bedrockSdk = makeMockSdk({ |
| 142 | invoke: () => { throw new Error('should not be called'); }, |
| 143 | stream: () => ({ body: fakeStream() }), |