ChatCompletionStreamingRunner.mjs 1.2 KB

123456789101112131415161718192021222324252627282930
  1. import { ChatCompletionStream } from "./ChatCompletionStream.mjs";
  2. export class ChatCompletionStreamingRunner extends ChatCompletionStream {
  3. static fromReadableStream(stream) {
  4. const runner = new ChatCompletionStreamingRunner(null);
  5. runner._run(() => runner._fromReadableStream(stream));
  6. return runner;
  7. }
  8. /** @deprecated - please use `runTools` instead. */
  9. static runFunctions(client, params, options) {
  10. const runner = new ChatCompletionStreamingRunner(null);
  11. const opts = {
  12. ...options,
  13. headers: { ...options?.headers, 'X-Stainless-Helper-Method': 'runFunctions' },
  14. };
  15. runner._run(() => runner._runFunctions(client, params, opts));
  16. return runner;
  17. }
  18. static runTools(client, params, options) {
  19. const runner = new ChatCompletionStreamingRunner(
  20. // @ts-expect-error TODO these types are incompatible
  21. params);
  22. const opts = {
  23. ...options,
  24. headers: { ...options?.headers, 'X-Stainless-Helper-Method': 'runTools' },
  25. };
  26. runner._run(() => runner._runTools(client, params, opts));
  27. return runner;
  28. }
  29. }
  30. //# sourceMappingURL=ChatCompletionStreamingRunner.mjs.map