(executor)
| 70245 | static createMessage(messages, params, options) { |
| 70246 | const runner = new _MessageStream(); |
| 70247 | for (const message of params.messages) { |
| 70248 | runner._addMessageParam(message); |
| 70249 | } |
| 70250 | runner._run(() => runner._createMessage(messages, { ...params, stream: true }, { ...options, headers: { ...options?.headers, "X-Stainless-Helper-Method": "stream" } })); |
| 70251 | return runner; |
| 70252 | } |
| 70253 | _run(executor) { |
| 70254 | executor().then(() => { |
| 70255 | this._emitFinal(); |
no test coverage detected