(params, thread, options)
| 83108 | for await (const event of stream4) { |
| 83109 | __classPrivateFieldGet12(this, _AssistantStream_instances, "m", _AssistantStream_addEvent).call(this, event); |
| 83110 | } |
| 83111 | if (stream4.controller.signal?.aborted) { |
| 83112 | throw new APIUserAbortError3(); |
| 83113 | } |
| 83114 | return this._addRun(__classPrivateFieldGet12(this, _AssistantStream_instances, "m", _AssistantStream_endRequest).call(this)); |
| 83115 | } |
| 83116 | static createThreadAssistantStream(params, thread, options) { |
| 83117 | const runner = new _AssistantStream(); |
| 83118 | runner._run(() => runner._threadAssistantStream(params, thread, { |
| 83119 | ...options, |
| 83120 | headers: { ...options?.headers, "X-Stainless-Helper-Method": "stream" } |
no test coverage detected