Node.js——stream

var fs = require(‘fs‘)

var rs = fs.createReadStream(‘./a.txt‘)

var ws = fs.createWriteStream(‘./Hello.txt‘,{
    flags: ‘a‘
})

rs.once(‘open‘,function () {
    console.log(‘可读流打开了‘)
})

rs.once(‘close‘,function () {
    console.log(‘可读流关闭了‘)
    ws.end()
})

rs.on(‘data‘,function (data) {
    ws.write(data)
})

ws.once(‘open‘,function () {
    console.log(‘可写流打开了‘)
})

ws.once(‘close‘,function () {
    console.log(‘可写流关闭了‘)
})

var fs = require(‘fs‘)

var rs = fs.createReadStream(‘./a.txt‘)

var ws = fs.createWriteStream(‘./Hello.txt‘,function () {
    console.log(‘可读流关闭了‘)
    @H_502_91@//@H_502_91@ ws.end()
})

@H_502_91@//@H_502_91@ rs.on(‘data‘,function (data) {@H_502_91@
//@H_502_91@     ws.write(data)@H_502_91@
//@H_502_91@ })

ws.once(‘open‘,function () {
    console.log(‘可写流关闭了‘)
})

rs.pipe(ws)