From 59f95009f2059c8e24e694768d261a0da02a7a9e Mon Sep 17 00:00:00 2001 From: Jay Kanjia <73180746+jaykanjia@users.noreply.github.com> Date: Wed, 29 Jan 2025 17:13:47 +0530 Subject: [PATCH] fix: delay in event emit (#10603) Co-authored-by: Riqwan Thamir --- .../modules/event-bus-local/src/services/event-bus-local.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/modules/event-bus-local/src/services/event-bus-local.ts b/packages/modules/event-bus-local/src/services/event-bus-local.ts index eb537c672b..1ac4001a32 100644 --- a/packages/modules/event-bus-local/src/services/event-bus-local.ts +++ b/packages/modules/event-bus-local/src/services/event-bus-local.ts @@ -91,7 +91,7 @@ export default class LocalEventBusService extends AbstractEventBusModuleService const { options, ...eventBody } = eventData const options_ = options as { delay: number } - const delay = options?.delay ? setTimeout : async () => {} + const delay = (ms?: number) => (ms ? setTimeout(ms) : Promise.resolve()) delay(options_?.delay).then(() => this.eventEmitter_.emit(eventData.name, eventBody) @@ -118,7 +118,7 @@ export default class LocalEventBusService extends AbstractEventBusModuleService const { options, ...eventBody } = event const options_ = options as { delay: number } - const delay = options?.delay ? setTimeout : async () => {} + const delay = (ms?: number) => (ms ? setTimeout(ms) : Promise.resolve()) delay(options_?.delay).then(() => this.eventEmitter_.emit(event.name, eventBody)