Sha256: b16473d44ffe0110f87734e1bee0f6d3e94cb695f316757da4205b80dbf9ec0a
Contents?: true
Size: 741 Bytes
Versions: 21
Compression:
Stored size: 741 Bytes
Contents
const { queue } = require('async');
const Fingerprinter = require('./fingerprinter');
class FingerprintQueue {
constructor(size = 5, printCanonicalAppMaps = true) {
this.size = size;
// eslint-disable-next-line no-use-before-define
this.handler = new Fingerprinter(printCanonicalAppMaps);
this.queue = queue(this.handler.fingerprint.bind(this.handler), this.size);
this.queue.pause();
}
setCounterFn(counterFn) {
this.handler.setCounterFn(counterFn);
}
async process() {
return new Promise((resolve, reject) => {
this.queue.drain(resolve);
this.queue.error(reject);
this.queue.resume();
});
}
push(job) {
this.queue.push(job);
}
}
module.exports = FingerprintQueue;
Version data entries
21 entries across 21 versions & 1 rubygems