FM / culvert

/usr/local/lib/node_modules/pm2/node_modules/culvert/

/usr/local/lib/node_modules/pm2/node_modules/culvert

Name	Size	Mode	Actions
channel.js	1505	0644	edit dl rm
consume.js	329	0644	edit dl rm
LICENSE	1077	0644	edit dl rm
package.json	594	0644	edit dl rm
README.md	2611	0644	edit dl rm

Edit: /usr/local/lib/node_modules/pm2/node_modules/culvert/channel.js (1505B)

"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 log(name) {
  return function (type, value) {
    console.info(name, type, value);
  };
}

cmd: