class CommandBus<CommandBase extends ICommand = ICommand> extends ObservableBus implements ICommandBus {
publisher: ICommandPublisher<CommandBase>
execute<T extends CommandBase, R = any>(command: T): Promise<R>
bind<T extends CommandBase>(handler: ICommandHandler<T, any>, id: string)
register(handlers: Type<ICommandHandler<ICommand, any>>[] = [])
protected registerHandler(handler: Type<ICommandHandler<ICommand, any>>)
constructor()
protected _subject$: Subject<T>
subject$
}
Methods
execute()
|
|---|
execute<T extends CommandBase, R = any>(command: T): Promise<R>
Parameters
| Option |
Type |
Description |
command
|
T |
|
Returns
Promise<R>
|
bind()
|
|---|
bind<T extends CommandBase>(handler: ICommandHandler<T, any>, id: string)
Parameters
|
register()
|
|---|
register(handlers: Type<ICommandHandler<ICommand, any>>[] = [])
Parameters
| Option |
Type |
Description |
handlers
|
Type>[] |
Optional. Default is [].
|
|
registerHandler()
|
|---|
protected registerHandler(handler: Type<ICommandHandler<ICommand, any>>)
Parameters
| Option |
Type |
Description |
handler
|
Type> |
|
|
