Skip to content

NatsConnectionLike

Defined in: src/io/broker/JetStreamActor.ts:570

Minimal NatsConnection surface the actor depends on. Exported so test seams (subclasses of JetStreamActor overriding createNatsConnection) can satisfy the same shape without pulling the real nats peer-dep.

closed(): Promise<Error | undefined>

Defined in: src/io/broker/JetStreamActor.ts:574

Promise<Error | undefined>


drain(): Promise<void>

Defined in: src/io/broker/JetStreamActor.ts:573

Promise<void>


jetstream(): JetStreamClientLike

Defined in: src/io/broker/JetStreamActor.ts:571

JetStreamClientLike


jetstreamManager(): Promise<JetStreamManagerLike>

Defined in: src/io/broker/JetStreamActor.ts:572

Promise<JetStreamManagerLike>