API reference / @chanx-js/client / core / StreamOptions

Interface: StreamOptions

Defined in: packages/client/src/core/stream.ts:1

Properties

limit?

optional limit?: number;

Defined in: packages/client/src/core/stream.ts:6

Messages held while the consumer is busy. Once full the oldest is dropped, so a slow for await body cannot grow memory without bound.

---

signal?

optional signal?: AbortSignal;

Defined in: packages/client/src/core/stream.ts:7