Queue.js
1011 字节
'use strict'
const DoublyLinkedList = require('./DoublyLinkedList')
const Deque = require('./Deque')
/**
* Sort of a internal queue for holding the waiting
* resource requets for a given "priority".
* Also handles managing timeouts rejections on items (is this the best place for this?)
* This is the last point where we know which queue a resourceRequest is in
*
*/
class Queue extends Deque {
/**
* Adds the obj to the end of the list for this slot
* we completely override the parent method because we need access to the
* node for our rejection handler
* @param {[type]} item [description]
*/
push (resourceRequest) {
const node = DoublyLinkedList.createNode(resourceRequest)
resourceRequest.promise.catch(this._createTimeoutRejectionHandler(node))
this._list.insertEnd(node)
}
_createTimeoutRejectionHandler (node) {
return (reason) => {
if (reason.name === 'TimeoutError') {
this._list.remove(node)
}
}
}
}
module.exports = Queue