FM / streaming

/opt/canhelp/node_modules/hono/dist/cjs/helper/streaming/

/opt/canhelp/node_modules/hono/dist/cjs/helper/streaming

Name	Size	Mode	Actions
index.js	1331	0644	edit dl rm
sse.js	3072	0644	edit dl rm
stream.js	1875	0644	edit dl rm
text.js	1333	0644	edit dl rm
utils.js	1339	0644	edit dl rm

Edit: /opt/canhelp/node_modules/hono/dist/cjs/helper/streaming/stream.js (1875B)

var __defProp = Object.defineProperty;
var __getOwnPropDesc = Object.getOwnPropertyDescriptor;
var __getOwnPropNames = Object.getOwnPropertyNames;
var __hasOwnProp = Object.prototype.hasOwnProperty;
var __export = (target, all) => {
  for (var name in all)
    __defProp(target, name, { get: all[name], enumerable: true });
};
var __copyProps = (to, from, except, desc) => {
  if (from && typeof from === "object" || typeof from === "function") {
    for (let key of __getOwnPropNames(from))
      if (!__hasOwnProp.call(to, key) && key !== except)
        __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });
  }
  return to;
};
var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod);
var stream_exports = {};
__export(stream_exports, {
  stream: () => stream
});
module.exports = __toCommonJS(stream_exports);
var import_stream = require("../../utils/stream");
var import_utils = require("./utils");
const contextStash = /* @__PURE__ */ new WeakMap();
const stream = (c, cb, onError) => {
  const { readable, writable } = new TransformStream();
  const stream2 = new import_stream.StreamingApi(writable, readable);
  if ((0, import_utils.isOldBunVersion)()) {
    c.req.raw.signal.addEventListener("abort", () => {
      if (!stream2.closed) {
        stream2.abort();
      }
    });
  }
  contextStash.set(stream2.responseReadable, c);
  (async () => {
    try {
      await cb(stream2);
    } catch (e) {
      if (e === void 0) {
      } else if (e instanceof Error && onError) {
        await onError(e, stream2);
      } else {
        console.error(e);
      }
    } finally {
      stream2.close();
    }
  })();
  return c.newResponse(stream2.responseReadable);
};
// Annotate the CommonJS export names for ESM import in node:
0 && (module.exports = {
  stream
});

cmd: