节点学校流-冒险#6连接

Question

我从一开始就倾向于node.js。溪流里有第六个问题--冒险@nodeschool，

您将在process.stdin上获得文本。在将文本写入标准输出之前，先缓冲文本并使用concat-stream模块将其反转。

我的回答是：

var concatStream = require('concat-stream');
var through2 = require('through2');
var split = require('split');
var inv = through2(trans, flush);
process.stdin
  .pipe(process.stdout)
  .pipe(concatStream(inv));

function trans (buffer, enc, callback){
  var tr = buffer.toString().split('').reverse().join('');
  this.push(tr);
  callback();
}

function flush (callback){
  callback();
}

我已经检查了解决方案，但我只想尝试模块"through2“。

它不能工作(似乎是无穷无尽的循环)，有人能帮上忙吗？非常感谢！

Answer 1

解决办法是：

​

const concat = require('concat-stream');
const through = require('through2');
const stream = require('stream');

function allRead(buf){
        const reversed = buf.toString().split('').reverse().join('');
        const streamReversed = stream.Readable.from(reversed); // or console.log(reversed)
        streamReversed.pipe(process.stdout);
}
process.stdin.pipe(concat(allRead));

​

您只需要通过管道将stdin流连接起来，并等待所有数据被收集。最后，反转所有缓冲区(转换为string )并将其发送到stdout (带有控制台日志或新流)。