|
Server : Apache System : Linux cloud.heroica.com.br 4.18.0-553.36.1.el8_10.x86_64 #1 SMP Wed Jan 22 03:07:54 EST 2025 x86_64 User : farolpborg ( 1053) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /proc/self/root/lib/node_modules/pm2/node_modules/culvert/ |
Upload File : |
"use strict";
module.exports = makeChannel;
function makeChannel(bufferSize, monitor) {
bufferSize = bufferSize|0;
var dataQueue = [];
var readQueue = [];
var drainList = [];
if (typeof monitor === "string") {
monitor = log(monitor);
}
return {
drain: drain,
put: put,
take: take,
};
function drain(callback) {
if (typeof callback !== "function") {
throw new TypeError("callback must be function");
}
if (dataQueue.length <= bufferSize) return callback();
drainList.push(callback);
}
// Returns true when it's safe to continue without draining
function put(item) {
if (monitor) monitor("put", item);
if (readQueue.length) {
if (monitor) monitor("take", item);
readQueue.shift()(null, item);
}
else {
dataQueue.push(item);
}
return dataQueue.length <= bufferSize;
}
function take(callback) {
if (typeof callback !== "function") {
throw new TypeError("callback must be function");
}
if (dataQueue.length) {
var item = dataQueue.shift();
if (monitor) monitor("take", item);
callback(null, item);
if (dataQueue.length <= bufferSize && drainList.length) {
var list = drainList;
drainList = [];
for (var i = 0; i < list.length; i++) {
list[i]();
}
}
return;
}
readQueue.push(callback);
}
}
function log(name) {
return function (type, value) {
console.info(name, type, value);
};
}