feat: use publisher from any bus

nestjs · Jul 9, 2022 · 33c85df · 33c85df
1 parent 4e0c1bf
commit 33c85df
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/command-bus.ts b/src/command-bus.ts
@@ -42,7 +42,7 @@ export class CommandBus<CommandBase extends ICommand = ICommand>
  if (!handler) {
  throw new CommandHandlerNotFoundException(commandId);
  }
- this.subject$.next(command);
+ this._publisher.publish(command);
  return handler.execute(command);
  }
 

diff --git a/src/query-bus.ts b/src/query-bus.ts
@@ -47,7 +47,7 @@ export class QueryBus<QueryBase extends IQuery = IQuery>
  throw new QueryHandlerNotFoundException(queryId);
  }
 
- this.subject$.next(query);
+ this._publisher.publish(query);
  const result = await handler.execute(query);
  return result as TResult;
  }