PATH:
usr
/
local
/
lib
/
node_modules
/
pm2
/
node_modules
/
culvert
"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); } }; }
[+]
..
[-] channel.js
[edit]
[-] package.json
[edit]
[-] README.md
[edit]
[-] consume.js
[edit]
[-] LICENSE
[edit]