pipe-promises.js

exports.pipe = function (source, sink) {
    var resolve, reject;
    return new Promise(function(resolve_, reject_) {
        resolve = resolve_;
        reject = reject_;
        source
          .on("error", reject)
          .pipe(sink)
          .on("error", reject);
          .on("finish", resolve);
    }).finally(function() {
        source.removeListener("error", reject);
        sink.removeListener("error", reject);
        sink.removeListener("finish", resolve);
    });
};