柯里化在Node.js文件流中用于解耦可复用的处理逻辑，通过预配置Transform或事件回调参数（如分隔符、编码、日志级别），避免硬编码和重复代码，提升.pipe()链的清晰性与灵活性。
在 Node.js 文件读取流（如 fs.createReadStream）中使用柯里化，核心目标不是“改造流本身”，而是**把流的处理逻辑解耦为可预配置、可复用的转换函数**，尤其适用于需要对不同文件类型或路径复用相同解析规则的场景。它不改变流的底层行为，但让 .pipe() 链中的 Transform 或回调更清晰、更灵活。
为什么要在文件流中用柯里化？
直接写 stream.pipe(parser()) 往往硬编码了参数（比如分隔符、编码、字段映射），导致：同一份 CSV 解析逻辑，换一个分隔符就得复制粘贴改代码；日志文件按行处理时，每种日志格式都要写一套 on('data') 回调。柯里化帮你把“变的部分”提前抽出来，生成专用处理器。
典型用法：为 Transform 流预设解析配置
以 CSV 行解析为例，原始 Transform 需要每次指定分隔符和是否跳过首行：
用柯里化封装后：
立即学习“Java免费学习笔记（深入）”；
const { delimiter = '\n', skipHeader = false, encoding = 'utf8' } = options;
return new Transform({
objectMode: true,
transform(chunk, encoding, callback) {
const text = chunk.toString(encoding);
const lines = text.split(delimiter).filter(line => line.trim());
if (skipHeader && lines.length > 0) lines.shift();
lines.forEach(line => this.push(line));
callback();
}
});
};
使用时按需注入配置：
fs.createReadStream('access.log').pipe(createLineParser({ delimiter: '\n' }))fs.createReadStream('data.csv').pipe(createLineParser({ delimiter: ',', skipHeader: true }))
配合事件回调做参数预绑定
当不用 Transform 而是监听 'data' 事件时，柯里化能避免重复判断：
const line = chunk.toString().trim();
if (!line) return;
if (line.includes('[ERROR]')) console.error(`[${logLevel}] ${line}`);
else if (line.includes('[WARN]')) console.warn(`[${logLevel}] ${line}`);
};
然后直接绑定：
readStream.on('data', handleLogLine('prod'))anotherStream.on('data', handleLogLine('dev'))
与可读流组合构建处理管道
把柯里化函数和 stream.pipeline 结合，形成声明式链路：
objectMode: true,
transform(chunk, _, cb) {
try {
const obj = JSON.parse(chunk.toString(), reviver);
this.push(obj);
} catch (e) {
this.emit('error', e);
}
cb();
}
});
// 使用
pipeline(
fs.createReadStream('events.jsonl'),
parseJsonLines((key, val) => key === 'timestamp' ? new Date(val) : val),
writeStream,
err => { if (err) console.error(err); }
);
这里 parseJsonLines 是一个柯里化工厂，返回定制化的 Transform 实例，reviver 被闭包捕获，无需每次解析都传。
