(
handler: (ctx: string, e: MessageDeliveryFailedEvent) => void
)
| 361 | ): () => void { |
| 362 | const payloadSchema = getKiloChatEventPayloadSchema(event); |
| 363 | return this.es.on(event, (context, payload) => { |
| 364 | const result = payloadSchema.safeParse(payload); |
| 365 | if (!result.success) return; |
| 366 | handler(context, result.data); |
| 367 | }); |
| 368 | } |
| 369 | |
| 370 | onMessageCreated(handler: (ctx: string, e: MessageCreatedEvent) => void): () => void { |
no test coverage detected