var rs=new (require('stream').Readable)();
var ws=new (require('stream').Writable)();rs._read=function(){this.push('send a msn for the first time');this.push('send a msn for the second time');this.push(null);
}ws._wirte=function(chunk,encoding,next){console.log(chunk.toString());next()
}var Duplex=function(){let duplex= new (require('stream').Duplex)();duplex._read=function(){this.push(null);}duplex._write=function(chunk,e,callback){this.push(chunk.toString()+'...by ztw');next()}return duplex;
}
var myDuplex=Duplex();rs.pipe(myDuplex).pipe(ws);

var buffer=new Buffer('Buffer Test','utf8');buffer.toString('utf8',0,4);   // 'Buff'   位置按buffer内的位置算，非String的位置。buffer.copy(buffer2, targetStart, sourceStart, sourceEnd) ;// 说形象点，按照[sourceStart,sourceEnd]对buffer进行裁剪，并从buffer2的targetStart位置，开始替换。buffer.fill('shit' ,  sourceStart, sourceEnd );//使用shit在buffer的裁剪区域进行填充，填充方式为：repeat;buffer.fill('shit') //全部填充buffer.write('strawberry', start,end);   //替换某个位置。Buffer.concat([buf1,buf2]); //合并两个Buffer;

var arryBuffer=new ArrayBuffer(10);   //Buffer,拥有10个字节的容量。
var arr1=new Int8Array(arryBuffer);//每个Int8Array(Unit8Array...)都带有一个ArrayBuffer。这里显示申明了而已。我们可以这样获得它：var buf=arr1.buffer;   //buf指向arryBuffer，两者是一样的。var arr2=new Int8Array(buf) ; //arr2与arr1使用同一空间，二者关联，值也相同。
var arr2=new Int8Array(buf.slice(5)); //只将5以后的空间分配给arr2，而arr1仍然全部占有。
new Buffer(buf) //可以得到这个Buffer。只能在nodeJs端使用。buf.typeLength  // 返回buf的字节容量大小。

function fsPromise(method){return function(...args){return new Promise((resolve,reject)=>{method.apply(method,args.concat([(err,data)=>{resolve(data)}]))})}
}

function thunkify(method){return function(){return function(...args){return function(fn){method(...args,fn);  //相同于 method.apply(method, args.concat[fn]);};}  }
}

var readFile=thunkify(fs.readFile);
var FsGen=function* (){yield readFile('fileOne','utf8');yield readFile('fileTwo','utf8');
}var fg=FsGen();
nextFile();              //调用nextFile,按顺序异步读取文件。function nextFile(err,data){let result=fg.next();data?console.log(data):0;if(!result.done) result.value(nextFile);
}

function toPromise(method){return function(){return functin(...args){return new Promise((resolve,reject)=>{method(...args,(...data)=>{resolve(data);   //把它小小升级一下，data为array型，以支持不同参型。})})}}
}process.stdin.setEncoding('utf8');
const stdinOnce=process.stdin.once.bind(process.stdin);//记得bind；toPromise(stdinOnce)('data').then(val=>{process.stdout.write(...val);console.log('step1');return toPromise(stdinOnce)('data');
})
.then(val=>{process.stdout.write(...val);console.log('step2');return toPromise(stdinOnce)('data');
})
.then(val=>{console.log('end');process.stdout.end();
})