import * as plugins from "./nodehash.plugins";

export let hashStreamPipeStop = (resolveFuntion) => {
    let forEach = (chunk:Buffer,enc,cb) => {
        resolveFuntion(chunk.toString("utf8"));
        cb(null,chunk);
    };

    let atEnd = (cb) => {
        cb();
    };
    
    return plugins.through2(forEach,atEnd);
};