Class BufferedRequest

constructor

• new BufferedRequest(): BufferedRequest

• Returns BufferedRequest

Static markAsDelivered

Static markAsRead

Static reqPerTimeout

• get reqPerTimeout(): number

• Returns number

• set reqPerTimeout(value): void

• Parameters

  • value: number

  Returns void

Static timeoutMills

• get timeoutMills(): number

• Returns number

• set timeoutMills(value): void

• Parameters

  • value: number

  Returns void

Static create

• create(reqPerTimeout?, timeoutMills?): {
      handleIdle() => void;
      handleProcessing() => void;
      invoke() => Promise<void>;
      push(func, lane?) => void;
      shift() => void;
  }

• Parameters

  • reqPerTimeout: number = REQ_PER_TIMEOUT

  • timeoutMills: number = TIMEOUT_MILLS

  Returns {
      handleIdle() => void;
      handleProcessing() => void;
      invoke() => Promise<void>;
      push(func, lane?) => void;
      shift() => void;
  }

  • handleIdle:function

    • handleIdle(): void

    • Returns void

  • handleProcessing:function

    • handleProcessing(): void

    • Returns void

  • invoke:function

    • invoke(): Promise<void>

    • Returns Promise<void>

  • push:function

    • push(func, lane?): void

    • Parameters

      • func: Func

      • Optional lane: string

      Returns void

  • shift:function

    • shift(): void

    • Returns void

Static updateMarkAsDeliveredOptions

• updateMarkAsDeliveredOptions(reqPerTimeout, timeoutMills): void

• Parameters

  • reqPerTimeout: number

  • timeoutMills: number

  Returns void

Static updateMarkAsReadOptions

• updateMarkAsReadOptions(reqPerTimeout, timeoutMills): void

• Parameters

  • reqPerTimeout: number

  • timeoutMills: number

  Returns void