Página generada desde el TSDoc de @styx/bus. No se edita a mano: bun run docs:gen la regenera y bun run docs:check falla si difiere.

Interface: IBusNatsCopiar enlace

Quien pide por el bus (el adapter de un servicio depende de esto, no de NATS).

ExtendsCopiar enlace

• IBusRequester.IBusEmitter

MethodsCopiar enlace

close()Copiar enlace

close(): Promise<void>

Drena y cierra la conexión NATS.

ReturnsCopiar enlace

Promise<void>

---

emit()Copiar enlace

emit<C>(contract, msg): BusResult<void>

evt por NATS core (observaciones latest-wins; sin persistencia ni ack).

Type ParametersCopiar enlace

CCopiar enlace

C extends IContract<"evt", TSchema, TSchema | undefined>

ParametersCopiar enlace

contractCopiar enlace

C

msgCopiar enlace

RequestOf<C>

ReturnsCopiar enlace

BusResult<void>

Inherited fromCopiar enlace

IBusEmitter.emit

---

emitAcked()Copiar enlace

emitAcked<C>(contract, msg): Promise<BusResult<number>>

evt a un stream JetStream con confirmación (el servicio es dueño del stream); devuelve el seq. Un payload fuera de contrato no sale: BUS_INVALID_REQUEST.

Type ParametersCopiar enlace

CCopiar enlace

C extends IContract<"evt", TSchema, TSchema | undefined>

ParametersCopiar enlace

contractCopiar enlace

C

msgCopiar enlace

RequestOf<C>

ReturnsCopiar enlace

Promise<BusResult<number>>

Inherited fromCopiar enlace

IBusEmitter.emitAcked

---

isConnected()Copiar enlace

isConnected(): boolean

Conexión establecida (falso durante una reconexión o tras cerrar): readiness.

ReturnsCopiar enlace

boolean

---

request()Copiar enlace

request<C>(contract, msg, opts?): Promise<BusResult<ReplyOf<C>>>

cmd/qry con respuesta verificada; los fallos del bus son BUS_*.

Type ParametersCopiar enlace

CCopiar enlace

C extends IContract<"cmd" | "qry", TSchema, TSchema | undefined>

ParametersCopiar enlace

contractCopiar enlace

C

msgCopiar enlace

RequestOf<C>

opts?Copiar enlace

IBusRequestOptions

ReturnsCopiar enlace

Promise<BusResult<ReplyOf<C>>>

Inherited fromCopiar enlace

IBusRequester.request

---

serve()Copiar enlace

serve(handlers): void

Registra y sirve los handlers del servicio (una vez; después el router queda congelado). Aparte de connect porque un handler puede depender de adapters que usan este mismo bus.

ParametersCopiar enlace

handlersCopiar enlace

readonly IHandler<IContract<ContractKind, TSchema, TSchema | undefined>>[]

ReturnsCopiar enlace

void