asyavee/medusa-store
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

fix: delay in event emit (#10603)

Browse Source 
Co-authored-by: Riqwan Thamir <rmthamir@gmail.com>
This commit is contained in:
Jay Kanjia
2025-01-29 12:43:47 +01:00
committed by GitHub
co-authored by Riqwan Thamir
parent 16fe43f214
commit 59f95009f2
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/modules/event-bus-local/src/services/event-bus-local.ts
+2 -2
View File
@@ -91,7 +91,7 @@ export default class LocalEventBusService extends AbstractEventBusModuleService
const { options, ...eventBody } = eventData const { options, ...eventBody } = eventData
const options_ = options as { delay: number } 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(() => delay(options_?.delay).then(() =>
this.eventEmitter_.emit(eventData.name, eventBody) this.eventEmitter_.emit(eventData.name, eventBody)
@@ -118,7 +118,7 @@ export default class LocalEventBusService extends AbstractEventBusModuleService
const { options, ...eventBody } = event const { options, ...eventBody } = event
const options_ = options as { delay: number } 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(() => delay(options_?.delay).then(() =>
this.eventEmitter_.emit(event.name, eventBody) this.eventEmitter_.emit(event.name, eventBody)