Aller au contenu
Français

SseOptionsBuilder

Ce contenu n’est pas encore disponible dans votre langue.

Defined in: src/io/broker/SseOptions.ts:23

new SseOptionsBuilder(): SseOptionsBuilder

SseOptionsBuilder

BrokerOptionsBuilder<SseOptionsType>.constructor

build(): Partial<T>

Defined in: src/util/OptionsBuilder.ts:51

Snapshot the set fields as an independent Partial<T> (own props only).

Partial<T>

BrokerOptionsBuilder.build


withCircuitBreaker(failureThreshold, resetMs): this

Defined in: src/io/broker/BrokerOptions.ts:125

Circuit breaker around connect attempts.

number

number

this

BrokerOptionsBuilder.withCircuitBreaker


withHeaders(headers): this

Defined in: src/io/broker/SseOptions.ts:35

Custom request headers.

Readonly<Record<string, string>>

this


withOutboundBuffer(limit): this

Defined in: src/io/broker/BrokerOptions.ts:130

Outbound buffer size (messages held while disconnected). Default 1000; 0 = fail-fast.

number

this

BrokerOptionsBuilder.withOutboundBuffer


withReconnect(policy): this

Defined in: src/io/broker/BrokerOptions.ts:120

Reconnect policy (or false to disable auto-reconnect).

false | { factor?: number; initialDelayMs?: number; maxAttempts?: number; maxDelayMs?: number; } | undefined

false


{ factor?: number; initialDelayMs?: number; maxAttempts?: number; maxDelayMs?: number; }

number

number

number

Cap on retry attempts. Default: Infinity (retry forever).

number


undefined

this

BrokerOptionsBuilder.withReconnect


withTarget(target): this

Defined in: src/io/broker/SseOptions.ts:40

Subscriber for inbound events. Required.

ActorRef<SseEvent>

this


withUrl(url): this

Defined in: src/io/broker/SseOptions.ts:30

SSE endpoint URL.

string

this


static create(): SseOptionsBuilder

Defined in: src/io/broker/SseOptions.ts:25

Start a fresh builder. Equivalent to new SseOptionsBuilder().

SseOptionsBuilder