MCPcopy
hub / github.com/di-sukharev/opencommit / createThreadAssistantStream

Method createThreadAssistantStream

out/cli.cjs:83110–83117  ·  view source on GitHub ↗
(params, thread, options)

Source from the content-addressed store, hash-verified

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" }

Callers 1

createAndRunStreamMethod · 0.80

Calls 2

_runMethod · 0.45

Tested by

no test coverage detected