Class Query<T>

constructor

• new Query<T>(header, subject, match?): Query<T>

• Type Parameters

  • T extends Message

  Parameters

  • header: Header
  • subject: Subject<T>
  • match: ((msg: T) => boolean) = ...
    • • (msg): boolean

      • Parameters

        • msg: T

        Returns boolean

  Returns Query<T>

header

log

match

rx

subject

tx

lock

• lock(millis?): Promise<boolean>

• Parameters

  • millis: number = 500

  Returns Promise<boolean>

run

• run(rxDelay?, retries?): Promise<undefined | T>

• Parameters

  • rxDelay: number = 5
  • retries: number = 5

  Returns Promise<undefined | T>

subscribe

• subscribe(matchNid?): void

• Parameters

  • matchNid: boolean = true

  Returns void

unlock

• unlock(): void

• Returns void