Options
All
  • Public
  • Public/Protected
  • All
Menu

Class SimpleCommandBus

Hierarchy

  • SimpleCommandBus

Implements

  • CommandBus
  • Disposable

Index

Constructors

Accessors

Methods

Constructors

constructor

  • new SimpleCommandBus(eventBus: EventBus, emitter: EmittableCommandBus, handlers?: Map<string, CommandHandler<any, any, any>>): SimpleCommandBus

Accessors

observer

  • get observer(): ObservableCommandBus

Methods

dispose

  • dispose(): Promise<void>

execute

  • execute<R, C>(command: C, options?: Partial<ExecuteActionOptions>): Promise<R>

  • Type parameters

    • R: Result<any, ResultHeaders, R> = Result<any, ResultHeaders>

    • C: Command<any, MessageHeaders, C> = Command<any, MessageHeaders>

    Parameters

    • command: C
    • Optional options: Partial<ExecuteActionOptions>

    Returns Promise<R>

executeAndForget

  • executeAndForget<C>(command: C): void

handle

  • handle<C, R, Es>(commandType: string, handler: CommandHandler<C, R, Es>): Removable

  • Type parameters

    • C: Command<any, MessageHeaders, C> = Command<any, MessageHeaders>

    • R: Result<any, ResultHeaders, R> = Result<any, ResultHeaders>

    • Es: Event<any, MessageHeaders>[] = []

    Parameters

    • commandType: string
    • handler: CommandHandler<C, R, Es>

    Returns Removable

Private processHandlerOutput

  • processHandlerOutput<R>(output: CommandHandlerOutputSync<R, []>): void | CommandResult<R>

Private resolveHandler

  • resolveHandler<C, R, Es>(command: Command<any, MessageHeaders>): CommandHandler<C, R, Es>

  • Type parameters

    • C: Command<any, MessageHeaders, C> = Command<any, MessageHeaders>

    • R: Result<any, ResultHeaders, R> = Result<any, ResultHeaders>

    • Es: Event<any, MessageHeaders>[] = []

    Parameters

    • command: Command<any, MessageHeaders>

    Returns CommandHandler<C, R, Es>

Generated using TypeDoc