@pkgai/sse-parser

@pkgai/sse-parser

SSE EventStream 数据解析器

安装

# ✨ Auto-detect
npx nypm install @pkgai/sse-parser

# npm
npm install @pkgai/sse-parser

# yarn
yarn add @pkgai/sse-parser

# pnpm
pnpm install @pkgai/sse-parser

# bun
bun install @pkgai/sse-parser

# deno
deno install @pkgai/sse-parser

ReadableStream

import { readableStream } from '@pkgai/sse-parser'

const response =await fetch('https://openai-like/v1/chat/completions',{
  method: 'POST',
  headers: {
    'Content-Type': 'application/json',
    Authorization: 'Bearer {API_KEY}',
  },
  body: JSON.stringify({
    model: 'qwq-32b',
    messages: [
      {
        role: 'user',
        content: '9.9和9.11谁大',
      },
    ],
    stream: true,
    stream_options: {
      include_usage: true,
    },
  })
})

for await (const chunk of readableStream(response.body!)) {
  console.log(chunk)
  // data: 
  console.log(chunk.data)
  // event:
  console.log(chunk.event)
}

Response

import { response } from '@pkgai/sse-parser'

const res =await fetch('https://openai-like/v1/chat/completions',{
  method: 'POST',
  headers: {
    'Content-Type': 'application/json',
    Authorization: 'Bearer {API_KEY}',
  },
  body: JSON.stringify({
    model: 'qwq-32b',
    messages: [
      {
        role: 'user',
        content: '9.9和9.11谁大',
      },
    ],
    stream: true,
    stream_options: {
      include_usage: true,
    },
  })
})

for await (const chunk of response(res)) {
  console.log(chunk)
  // data: 
  console.log(chunk.data)
  // event:
  console.log(chunk.event)
}

EventSourceStream

将 ReadableStream<Uint8Array> 转换为 ReadableStream<EventSourceMessage>

import { EventSourceStream } from '@pkgai/sse-parser'

const readableStream = getReadableStream()
readableStream.pipeThrough(new EventSourceStream())

贡献者

Published under the MIT license. Made by @Colourlessglow and community 💛

🤖 auto updated with automd