Extracted from openai-node
http-streamify is a library for creating and handling streams, especially for Server-Sent Events (SSE) and newline-delimited JSON streams.
http-streamify 是一个用于处理 Server-Sent Events (SSE) 和可读流的 JavaScript 库。该库适用于在浏览器和 Node.js 环境中使用。
You can install the package using npm:
导入 http-streamify
npm install http-streamifyThe fromSSEResponse method creates a Stream object from an SSE response.
从 SSE 响应创建 Stream 的示例
const response = await fetch('/sse-endpoint');
const controller = new AbortController();
const stream = Stream.fromSSEResponse(response, controller);
for await (const data of stream) {
console.log(data); // { event: 'message', data: 'Hello, world!' }
}The fromReadableStream method creates a Stream object from a readable stream, where each item is a newline-delimited JSON value.
从可读流创建 Stream 的示例
// const readableStream = new ReadableStream(/* ... */);
const readableStream = fetch('/readable-stream-endpoint');
const controller = new AbortController();
const stream = Stream.fromReadableStream(readableStream, controller);
for await (const data of stream) {
console.log(data); // { event: 'message', data: 'Hello, world!' }
}MIT