(generator: AsyncGenerator<AIMessageChunk>)
| 332 | } |
| 333 | |
| 334 | async *_transform(generator: AsyncGenerator<AIMessageChunk>): AsyncGenerator<string> { |
| 335 | for await (const chunk of generator) { |
| 336 | const text = extractTextFromChunk(chunk) |
| 337 | if (text) { |
| 338 | yield text |
| 339 | } |
| 340 | } |
| 341 | } |
| 342 | |
| 343 | async *transform(generator: AsyncGenerator<AIMessageChunk>, options?: Partial<RunnableConfig>): AsyncGenerator<string> { |
| 344 | yield* this._transformStreamWithConfig(generator, this._transform.bind(this), options) |
nothing calls this directly
no test coverage detected