Server-Sent Events (SSE) Parser / Event Stream Parser

A lightweight Server-Sent Events (SSE) parser implementation following the HTML Living Standard specification. This package is designed to work with the Web Streams API and is fully compatible with modern browsers and Node.js.

Installation

1npm install event-stream-parser
2# or
3yarn add event-stream-parser
4# or
5pnpm add event-stream-parser

Usage

You can import the package in two ways:

1// Using v1 explicitly
2import { parse } from 'event-stream-parser/v1';
3// Using default import (same as v1)
4import { parse } from 'event-stream-parser';
5
6// Example with fetch
7const response = await fetch('https://api.example.com/events', {
8  headers: {
9    Accept: 'text/event-stream',
10  },
11});
12
13if (!response.body) {
14  throw new Error('Response body is null');
15}
16
17const eventStream = await parse(response.body);
18
19eventStream.pipeTo(
20  new WritableStream({
21    write(event) {
22      console.log('Event type:', event.type);
23      console.log('Event data:', event.data);
24      console.log('Last event ID:', event.lastEventId);
25    },
26  })
27);

Features

• 🚀 Lightweight and zero dependencies
• 🌊 Works with Web Streams API
• 📦 Full TypeScript support
• ✨ Follows SSE specification
• 🔍 Handles all SSE fields (event, data, id, retry)

API

parse(stream: ReadableStream): Promise<ReadableStream>

Parses a readable stream of SSE data and returns a readable stream of MessageEvent objects.

Parameters

• stream: A ReadableStream<Uint8Array> containing the SSE data

Returns

• A Promise<ReadableStream<MessageEvent>> that yields parsed SSE events

License

MIT

Contributing

Contributions are welcome! Please feel free to submit a Pull Request.