node-streams/Writable.js at master · perguth/node-streams · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
var Writable = require('stream').Writable

// -- Long version --
var inherits = require('inherits')

inherits(MyWritable, Writable)

function MyWritable () {
  Writable.call(this)

  this._write = (buffer, encoding, next) => {
    console.log(buffer)
    next()
  }
}
var writeStream = new MyWritable()

// -- Short version --
var writeStream2 = new Writable({
  write: (buffer, encoding, next) => {
    console.log(buffer)
    next()
  }
})

// -- Methods --

var data = 'payload'
writeStream.write(data)

// .write(chunk[, encoding][, callback]) -> <Boolean>
// .setDefaultEncoding(encoding)
// .end([chunk][, encoding][, callback])
// .cork()
// .uncork()

// -- Events --

writeStream.on('drain', () => {
  writeStream.write(data)
})

// drain
// finish
// error
// finish
// pipe
// unpipe