pipe with promises

pipe-promises.js

exports.pipe = function (source, sink) {
    var deferred = Q.defer();

    source
        .on("end", deferred.resolve)
        .on("error", deferred.reject)
        .pipe(sink)
        .on("error", deferred.reject);

    deferred.promise.finally(function () {
        source.removeListener("end", deferred.resolve);
        source.removeListener("error", deferred.reject);
        sink.removeListener("error", deferred.reject);
    });

    return deferred.promise;
};