wrappers.cjs 758 B

123456789101112131415161718
  1. "use strict";
  2. Object.defineProperty(exports, "__esModule", { value: true });
  3. exports.convertToHttpEventStream = void 0;
  4. const stream_js_1 = require("../utils/stream.cjs");
  5. function convertToHttpEventStream(stream) {
  6. const encoder = new TextEncoder();
  7. const finalStream = new ReadableStream({
  8. async start(controller) {
  9. for await (const chunk of stream) {
  10. controller.enqueue(encoder.encode(`event: data\ndata: ${JSON.stringify(chunk)}\n\n`));
  11. }
  12. controller.enqueue(encoder.encode("event: end\n\n"));
  13. controller.close();
  14. },
  15. });
  16. return stream_js_1.IterableReadableStream.fromReadableStream(finalStream);
  17. }
  18. exports.convertToHttpEventStream = convertToHttpEventStream;