first commit

wangzhibo

2026-05-09 53418655c061ac26f66058253f39200aced1ab1d

1
2
3
4
5
6
7
8
9
10
11
12
'use strict'
 
const { TimeoutError } = require('../../errors')
 
/**
 * Flushes the queue by rejecting all pending requests with a timeout error.
 */
module.exports = function purge () {
  this.flush(function flushCB (a, b, c, cb) {
    cb(new TimeoutError('request queue timeout'))
  })
}