能否实现流操作

[loohoo]

如果实现支持pipe 应该怎么改造呢:

fs.createReadStream(".secret.txt")
  .pipe(new xxtea.createEncrypt('key')))
  .pipe(fs.createWriteStream('out.text.tea'))
  .on('close', decrypt);

[andot]

xxtea 不是一个流加密算法，我不知道怎么改造。