nodejs中使用数据流分布处理

因为nodejs这种异步处理的机制，很少见到关于数据流的在处理方法，比如我去接收一个数据流,这个数据流不能两个程序同时接收,会丢数据如果有两个数据接收端，所以我的代码大概是

#app1.js
readStream.on('data', function(chunk) { // 当有数据流出时，写入数据
    save(chunk);
});
#app2.js

但是我的这个save操作非常的耗时，我又想让这个save的速度尽量能跟得上stream,所以我打算pm2 10个app2来专门处理这个save,请问有什么好的方法可以让app1的chunk传输到app2中？