JsonFrameLimits
SUPPORT · interface · 类型合同
Bounds applied while scanning a streamed text.
导入
ts
import type { JsonFrameLimits } from '@jangts/agent-core/json-transport';js
/** @typedef {import('@jangts/agent-core/json-transport').JsonFrameLimits} JsonFrameLimits */其他公开入口：@jangts/agent-core、@jangts/agent-core/types、@jangts/agent-core/structs、@jangts/agent-core/json-transport、@jangts/agent-core/support。
定义
ts
interface JsonFrameLimits字段结构
| 字段 | 类型 | 必需 | 说明 |
|---|---|---|---|
maxFrames | number | 必需 | Maximum number of complete frames accepted. |
maxExtraClosings | number | 必需 | Stray closing braces tolerated outside frames, covering transports that repeat a delimiter. |
maxFrameChars | number | undefined | 可省略 | Optional per-frame character cap so a single frame cannot amplify into an oversized parse. |
使用示例
- SSE、JSON 帧与有界事件流：复用传输机制，保持取消和背压；协议解析与业务校验仍各自负责。
在本地解析一帧 SSE
入门 · Node.js
ts
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);js
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);生产者等待每一次事件交付
配置 · Node.js
ts
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);js
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);