fix(event-bus) force handler return to always be a promise, since rom…

… don't accept undefined value
nestjs · Jun 3, 2022 · b06109a · b06109a
1 parent 6b8c2c6
commit b06109a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/event-bus.ts b/src/event-bus.ts
@@ -71,7 +71,7 @@ export class EventBus<EventBase extends IEvent = IEvent>
  bind(handler: IEventHandler<EventBase>, id: string) {
  const stream$ = id ? this.ofEventId(id) : this.subject$;
  const subscription = stream$
- .pipe(mergeMap((event) => from(handler.handle(event))))
+ .pipe(mergeMap((event) => from(Promise.resolve(handler.handle(event)))))
  .subscribe({
  error: (error) => {
  this._logger.error(