Options
All
  • Public
  • Public/Protected
  • All
Menu

Class SimpleQueryBus

Hierarchy

  • SimpleQueryBus

Implements

  • QueryBus
  • Disposable

Index

Constructors

Accessors

Methods

Constructors

constructor

  • new SimpleQueryBus(emitter: EmittableQueryBus, handlers?: Map<string, QueryHandler<any, any>>): SimpleQueryBus

Accessors

observe

  • get observe(): ObservableQueryBus

Methods

dispose

  • dispose(): Promise<void>

execute

  • execute<R, Q>(query: Q, options?: Partial<ExecuteActionOptions>): Promise<R>

  • Type parameters

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

    • Q: Query<any, MessageHeaders, Q> = Query<any, MessageHeaders>

    Parameters

    • query: Q
    • Optional options: Partial<ExecuteActionOptions>

    Returns Promise<R>

handle

  • handle<C, R>(queryType: string, handler: QueryHandler<C, R>): Removable

  • Type parameters

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

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

    Parameters

    • queryType: string
    • handler: QueryHandler<C, R>

    Returns Removable

Private resolveHandler

  • resolveHandler<Q, R>(query: Query<any, MessageHeaders>): QueryHandler<Q, R>

  • Type parameters

    • Q: Query<any, MessageHeaders, Q> = Query<any, MessageHeaders>

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

    Parameters

    • query: Query<any, MessageHeaders>

    Returns QueryHandler<Q, R>

Generated using TypeDoc