/
opt
/
canhelp
/
node_modules
/
hono
/
dist
/
helper
/
streaming
/
/opt/canhelp/node_modules/hono/dist/helper/streaming
mkdir
upload
Name
Size
Mode
Actions
index.js
233
0644
edit
dl
rm
sse.js
2058
0644
edit
dl
rm
stream.js
893
0644
edit
dl
rm
text.js
349
0644
edit
dl
rm
utils.js
367
0644
edit
dl
rm
Edit:
/opt/canhelp/node_modules/hono/dist/helper/streaming/stream.js
(893B)
// src/helper/streaming/stream.ts import { StreamingApi } from "../../utils/stream.js"; import { isOldBunVersion } from "./utils.js"; var contextStash = /* @__PURE__ */ new WeakMap(); var stream = (c, cb, onError) => { const { readable, writable } = new TransformStream(); const stream2 = new StreamingApi(writable, readable); if (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); }; export { stream };
Save
cmd:
run