pipe with bluebird

pipe-bluebird.js

var Promise = require("bluebird");

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

  }).finally(function() {
    console.log('finally');
    source.removeListener("error", reject);
    sink.removeListener("error", reject);
    sink.removeListener("finish", resolve);
  });
};