SDK y paquetes@styx/busindexinterfaces

Interface: IBusEmitter

Referencia de @styx/bus generada de su TSDoc.

ImplementadoSin versión del tren todavía· generada desde packages/bus/package.json

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: IBusEmitter

Quien publica evt.

Extended by

Methods

emit()

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

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

Type Parameters

C

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

Parameters

contract

C

msg

RequestOf<C>

Returns

BusResult<void>


emitAcked()

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 Parameters

C

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

Parameters

contract

C

msg

RequestOf<C>

Returns

Promise<BusResult<number>>