Edit File: consume.js
"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); } }; }
Back to File Manager