Options
All
  • Public
  • Public/Protected
  • All
Menu

Class Request<T>

Type parameters

  • T = string[]

Hierarchy

  • Request

Index

Enumerations

Interfaces

Type aliases

Constructors

Properties

Accessors

Methods

Type aliases

Static ResponseFormater

ResponseFormater<T>: (words: Word[]) => T

Type parameters

  • T

Type declaration

    • (words: Word[]): T

    • Parameters

      Returns T

Static ResponseParameter

ResponseParameter: Parameter | Subset

Static Send

Send: (req: Request<any>) => void

Type declaration

Static TimeoutHandler

TimeoutHandler: (data: TimeoutHandlerProps) => void

Type declaration

Static TimeoutHandlerProps

TimeoutHandlerProps: { request: Request<any>; timeout: number }

Type declaration

  • request: Request<any>
  • timeout: number

Constructors

constructor

Properties

Private callbacks

callbacks: ((data: T) => void)[] = []

Private fulfill

fulfill: any

Private nodeSetTimeout

nodeSetTimeout: any

Readonly packet

packet: Packet

priorized

priorized: boolean = false

Private reject

reject: any

removeWhenReconnect

removeWhenReconnect: boolean = false

Optional response

response: Packet

Private responseParams

responseParams: ResponseParameter[] = []

Private sendable

sendable: Send

Private stack

stack: undefined | string = (new Error()).stack

Private timeout

timeout: number

Private timeoutHandler

timeoutHandler: TimeoutHandler

Static DEFAULT_TIMEOUT

DEFAULT_TIMEOUT: number = 10 * 1000

Static RESPONSE_OK

RESPONSE_OK: string = "OK"

Accessors

sequenceNumber

  • get sequenceNumber(): number

Methods

clearPendingTimeout

  • clearPendingTimeout(): void

expect

format

Private formater

  • formater(words: Word[]): any

getContentWords

  • getContentWords(): Word[]

getResponse

  • getResponse(): string

getResponseContent

  • getResponseContent(): T

Private handleTimeout

  • handleTimeout(): void

isOk

  • isOk(): boolean

onResolved

  • onResolved(cb: (data: T) => void): void

priorize

  • priorize(): this

  • marks the request as a priority request this will make the query send this packet first and withhold all other queued packets till this has finnished

    Returns this

removeOnReconnect

  • removeOnReconnect(): this

send

  • send(): Promise<T>

setResponse

  • setResponse(packet: Packet): any

Generated using TypeDoc