Options
All
  • Public
  • Public/Protected
  • All
Menu

Class GroupRequestQueue

Hierarchy

  • GroupRequestQueue

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

  • new GroupRequestQueue(reqParams: { data: any[] | DataSchema }, reqAPI: (paramA: any, paramB?: any, paramC?: any, paramD?: any) => Promise<any>, maxParallel?: number, maxFragNum?: number, reqEndCallback?: () => void, stepSuccCallback?: () => void): GroupRequestQueue

  • Parameters

    • reqParams: { data: any[] | DataSchema }
      • [key: string]: any
      • data: any[] | DataSchema
    • reqAPI: (paramA: any, paramB?: any, paramC?: any, paramD?: any) => Promise<any>
        • (paramA: any, paramB?: any, paramC?: any, paramD?: any): Promise<any>

        • Parameters

          • paramA: any
          • Optional paramB: any
          • Optional paramC: any
          • Optional paramD: any

          Returns Promise<any>

    • maxParallel: number = 1
    • maxFragNum: number = 5000
    • reqEndCallback: () => void = ...
        • (): void

        • Returns void

    • stepSuccCallback: () => void = ...
        • (): void

        • Returns void

    Returns GroupRequestQueue

Properties

_maxParallel

_maxParallel: number

dataTransform

dataTransform: (queue: any[]) => void

Type declaration

    • (queue: any[]): void

    • Parameters

      • queue: any[]

      Returns void

failedQueue

failedQueue: QueueItem[]

maxFragNum

maxFragNum: number

originReqParams

originReqParams: { data: any[] | DataSchema }

Type declaration

  • [key: string]: any
  • data: any[] | DataSchema

Optional promise

promise: Promise<unknown>

queue

queue: QueueItem[]

Optional reject

reject: (value?: unknown) => void

Type declaration

    • (value?: unknown): void

    • Parameters

      • Optional value: unknown

      Returns void

reqAPI

reqAPI: (paramA: any, paramB?: any, paramC?: any, paramD?: any) => Promise<any>

Type declaration

    • (paramA: any, paramB?: any, paramC?: any, paramD?: any): Promise<any>

    • Parameters

      • paramA: any
      • Optional paramB: any
      • Optional paramC: any
      • Optional paramD: any

      Returns Promise<any>

reqEndCallback

reqEndCallback: (data: { errData: { data: any[]; err: any }[]; succData: any[] }) => void

Type declaration

    • (data: { errData: { data: any[]; err: any }[]; succData: any[] }): void

    • Parameters

      • data: { errData: { data: any[]; err: any }[]; succData: any[] }
        • errData: { data: any[]; err: any }[]
        • succData: any[]

      Returns void

requestingQueue

requestingQueue: QueueItem[]

Optional resolve

resolve: (value?: unknown) => void

Type declaration

    • (value?: unknown): void

    • Parameters

      • Optional value: unknown

      Returns void

stepSuccCallback

stepSuccCallback: (data: any) => void

Type declaration

    • (data: any): void

    • Parameters

      • data: any

      Returns void

successQueue

successQueue: QueueItem[]

waitingQueue

waitingQueue: QueueItem[]

Accessors

maxParallel

  • get maxParallel(): number
  • set maxParallel(val: number): void

  • Returns number

  • Parameters

    • val: number

    Returns void

Methods

checkIsFinalReq

  • checkIsFinalReq(): boolean

  • Returns boolean

clampLimit

  • clampLimit(val: number, min: number, max: number): number

  • Parameters

    • val: number
    • min: number
    • max: number

    Returns number

destroy

  • destroy(): void

  • Returns void

grouping

  • grouping(): any[]

  • Returns any[]

initQueue

  • initQueue(): void

  • Returns void

initRequest

  • initRequest(): void

  • Returns void

reqNext

  • reqNext(queueItem: QueueItem): void

  • Parameters

    • queueItem: QueueItem

    Returns void

resetQueue

  • resetQueue(): void

  • Returns void

setOriginReqParams

  • setOriginReqParams(reqParams: { data: any[] | DataSchema }): void

  • Parameters

    • reqParams: { data: any[] | DataSchema }
      • [key: string]: any
      • data: any[] | DataSchema

    Returns void

startRequesting

  • startRequesting(): Promise<unknown>

  • Returns Promise<unknown>

updateQueue

  • updateQueue(): void

  • Returns void