@server-sent-stream/node
This package allows you to consume server-sent events through Node's stream API.
Usage
This package can be used as an ESM or CommonJS module:
import EventSourceStream from '@server-sent-stream/node';const EventSourceStream = require('@server-sent-stream/node');The EventSourceStream is a Node stream.Transform. It consumes a stream of binary data (e.g. Buffers or Uint8Arrays), and produces a stream of MessageEvents.
You can use it with any Node Readable stream, like the kind returned by node-fetch:
// Fetch some URL that returns an event stream
const response = await fetch('https://example.com/events', {body: '...'});
// Pipe the response body into an EventSourceStream
const decoder = new EventSourceStream();
decoder.on('data', message => {
// The value will be a `MessageEvent`.
console.log(message);
// MessageEvent {data: 'message data', lastEventId: '', …}
})
response.body.pipe(decoder);Related packages
If you want a streaming interface for the Web Streams API, so you can use this in the browser, see @server-sent-stream/web. For just the event stream parser, see @server-sent-stream/parser.