ChatCompletionStreamingRunner.js 1.0 KB

123456789101112131415161718192021222324
  1. "use strict";
  2. Object.defineProperty(exports, "__esModule", { value: true });
  3. exports.ChatCompletionStreamingRunner = void 0;
  4. const ChatCompletionStream_1 = require("./ChatCompletionStream.js");
  5. class ChatCompletionStreamingRunner extends ChatCompletionStream_1.ChatCompletionStream {
  6. static fromReadableStream(stream) {
  7. const runner = new ChatCompletionStreamingRunner(null);
  8. runner._run(() => runner._fromReadableStream(stream));
  9. return runner;
  10. }
  11. static runTools(client, params, options) {
  12. const runner = new ChatCompletionStreamingRunner(
  13. // @ts-expect-error TODO these types are incompatible
  14. params);
  15. const opts = {
  16. ...options,
  17. headers: { ...options?.headers, 'X-Stainless-Helper-Method': 'runTools' },
  18. };
  19. runner._run(() => runner._runTools(client, params, opts));
  20. return runner;
  21. }
  22. }
  23. exports.ChatCompletionStreamingRunner = ChatCompletionStreamingRunner;
  24. //# sourceMappingURL=ChatCompletionStreamingRunner.js.map