Estoy tratando de implementar un trabajador asíncrono con la función lambda sin servidor con la ayuda del módulo eventEmitter de nestjs.

El controlador se invoca al emitir un evento, pero la función se cierra antes de la llamada async/await.

He intentado usar las funciones emit y emitAsync y diferentes argumentos para @OnEvent(AccountEvents.NEW_ACCOUNT, {async:true, promisify:true})

Fragmento del productor

 public async execute(event: EventDetail): Promise<void> { await this.eventEmitter.emitAsync(AccountEvents.NEW_ACCOUNT, event); }

Fragmento de oyente

 @OnEvent(AccountEvents.NEW_ACCOUNT) public async handleAccountCreatedEvent(event: EventDetail): Promise<void> { this.logger.log({ message: `Log1: ${AccountEvents.NEW_ACCOUNT} Handler`, event }); const message = await this.testAsync(); this.logger.log({ message }); this.logger.log({ message: 'Log 3: Event Processing Successfuly Completed' }); } private testAsync(): Promise<string> { return new Promise(res => { setTimeout(() => { res('Log 2: Promise resolved after one sec'); }, 1000); }); }

Salida esperada: las 3 declaraciones de registro Salida real: solo la primera declaración de registro (Log1)