encodeSseEvent

SUPPORT · function · Runtime value

Encode one event in the server-sent events wire format.

Every line of data gets its own data: field, because a raw newline would start a new field.

Import

TypeScript

import { encodeSseEvent } from '@jangts/agent-core/sse';

JavaScript

import { encodeSseEvent } from '@jangts/agent-core/sse';

Other public entry points:@jangts/agent-core, @jangts/agent-core/types, @jangts/agent-core/sse, @jangts/agent-core/support.

Definition

Call

encodeSseEvent(event: SseOutputEvent): string

Encode one event in the server-sent events wire format.

Every line of data gets its own data: field, because a raw newline would start a new field.

Parameter	Type	Passing	Description
event	SseOutputEvent	Required	—

Fields of event

Field	Type	Required	Description
event	string	Required	Event name; must not contain a line break.
data	string	Required	Payload text; each line becomes its own data: field.

Returns: string.

Examples

• SSE, JSON frames, and bounded event streams: Reuse transport mechanics while preserving cancellation and backpressure; protocol parsing and business validation remain separate.

Parse one SSE frame locally

Beginner · Node.js

TypeScript

import { Support } from '@jangts/agent-core';
const frame = Support.encodeSseEvent({ event: 'status', data: JSON.stringify({ phase: 'thinking' }) });
const body = new Response(frame).body!;
for await (const event of Support.readSse(body)) console.log(event.event, event.data);

JavaScript

import { Support } from '@jangts/agent-core';
const frame = Support.encodeSseEvent({ event: 'status', data: JSON.stringify({ phase: 'thinking' }) });
const body = new Response(frame).body;
for await (const event of Support.readSse(body))
    console.log(event.event, event.data);

Producer waits for each event delivery

Configuration · Node.js

TypeScript

import { Support } from '@jangts/agent-core';
const signal = new AbortController().signal;
const stream = Support.streamEvents<{ phase: string }>(async emit => {
  await emit({ phase: 'preparing' });
  await emit({ phase: 'complete' });
}, { signal });
for await (const event of stream) console.log(event.phase);

JavaScript

import { Support } from '@jangts/agent-core';
const signal = new AbortController().signal;
const stream = Support.streamEvents(async (emit) => {
    await emit({ phase: 'preparing' });
    await emit({ phase: 'complete' });
}, { signal });
for await (const event of stream)
    console.log(event.phase);

Explicitly limit JSON frame count and surrounding content

Extension · Node.js

TypeScript

import { Support } from '@jangts/agent-core';
const text = '{"kind":"reply","answer":"服务正常"}';
console.log(Support.scanJsonObjectFrames(text));
console.log(Support.parseJsonFrames(text, { maxFrames: 1, maxExtraClosings: 0 }));
const sent: string[] = [];
await Support.writeSseFrame({
  writer: { write(frame) { sent.push(frame); return true; }, async waitForDrain() {} },
  frame: Support.encodeSseEvent({ event: 'answer', data: text }),
}, { signal: new AbortController().signal });
console.log(sent);

JavaScript

import { Support } from '@jangts/agent-core';
const text = '{"kind":"reply","answer":"服务正常"}';
console.log(Support.scanJsonObjectFrames(text));
console.log(Support.parseJsonFrames(text, { maxFrames: 1, maxExtraClosings: 0 }));
const sent = [];
await Support.writeSseFrame({
    writer: { write(frame) { sent.push(frame); return true; }, async waitForDrain() { } },
    frame: Support.encodeSseEvent({ event: 'answer', data: text }),
}, { signal: new AbortController().signal });
console.log(sent);

Related policy source

• Single-slot handoff and backpressure in event streams

Related definitions

• SseOutputEvent