Server : Apache System : Linux profile 3.10.0-1160.88.1.el7.x86_64 #1 SMP Tue Mar 7 15:41:52 UTC 2023 x86_64 User : apache ( 48) PHP Version : 8.0.28 Disable Function : NONE Directory :  /lib/node_modules/pm2/node_modules/culvert/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

"use strict";

module.exports = consume;

function consume(channel, emit) {
  return function (callback) {
    channel.take(onItem);
    function onItem(err, item) {
      if (item === undefined) return callback(err);
      try { emit(item); }
      catch (err) { return callback(err); }
      channel.take(onItem);
    }
  };
}