import {Queue} from '@ericblade/mws-advanced/lib/endpoints/Queue.js'

public class | source

Queue

Constructor Summary

Public Constructor
public	constructor()

Member Summary

Public Members
public	action: *
public	api: *
public	category: *
public	inFlight: number
public	maxInFlight: *
public	queue: *[]
public	queueTimer: *
public	resetDrainTimeout: *
public	restoreRate: *
public	singleDrain: boolean
public	throttleCalls: number

Method Summary

Public Methods
public	complete()
public	drainQueue()
public	fail(err: , failedItem: )
public	onQueueTimer()
public	request(params: , options: ): *
public	runQueue()
public	setThrottleTimer()
public	throttle()

Public Constructors

public constructor() source

Public Members

public action: * source

public api: * source

public category: * source

public inFlight: number source

public maxInFlight: * source

public queue: *[] source

public queueTimer: * source

public resetDrainTimeout: * source

public restoreRate: * source

public singleDrain: boolean source

public throttleCalls: number source

Public Methods

public complete() source

public drainQueue() source

public fail(err: , failedItem: ) source

Params:

Name	Type	Attribute	Description
err	*
failedItem	*

public onQueueTimer() source

public request(params: , options: ): * source

Params:

Name	Type	Attribute	Description
params	*
options	*

Return:

public runQueue() source

public setThrottleTimer() source

public throttle() source

Queue

Constructor Summary

Member Summary

Method Summary

Public Constructors

public constructor() source

Public Members

public action: * source

public api: * source

public category: * source

public inFlight: number source

public maxInFlight: * source

public queue: *[] source

public queueTimer: * source

public resetDrainTimeout: * source

public restoreRate: * source

public singleDrain: boolean source

public throttleCalls: number source

Public Methods

public complete() source

public drainQueue() source

public fail(err: *, failedItem: *) source

Params:

public onQueueTimer() source

public request(params: *, options: *): * source

Params:

Return:

public runQueue() source

public setThrottleTimer() source

public throttle() source

public fail(err: , failedItem: ) source

public request(params: , options: ): * source