0

読み取り可能なストリームを作成するコードがあります。getStream メソッドでストリームの名前を設定したいと思います。以下のようにプロパティを設定してみました。onceFunction のプロパティにアクセスできますが、マップ Function のプロパティにアクセスできません。私が間違っていることを教えてください

var onceFunction = function(str1,record) {
    console.log("OnceFunction",this.nodeName);
}
var getStream = function(csvData) {
    var dirNames = csvData.split("/");
    var nodeName = dirNames[dirNames.length-2];
    var fileName = csvData;
    stream = fs.createReadStream(csvData);
    stream.nodeName = dirNames[dirNames.length-2];

    return stream;
};
var myFileList = ["D:\mypath\file"];

for ( var i = 0; i< myFileList.length; i++ ) {
    getStream(myFileList[i])
        .once('data',onceFunction)
        .pipe(es.split())
        .on('end',endFunction)
        .pipe(es.map(function(data,cb) {
            console.log(this.nodeName);

        }));
}
4

1 に答える 1