#through

Easy way to create a Stream that is both readable and writable.

• Pass in optional write and end methods.
• through takes care of pause/resume logic if you use this.queue(data) instead of this.emit('data', data).
• Use this.pause() and this.resume() to manage flow.
• Check this.paused to see current flow state. (write always returns !this.paused).

This function is the basis for most of the synchronous streams in event-stream.

1var through = require('through')
2
3through(function write(data) {
4    this.queue(data) //data *must* not be null
5  },
6  function end () { //optional
7    this.queue(null)
8  })

Or, can also be used without buffering on pause, use this.emit('data', data), and this.emit('end')

1var through = require('through')
2
3through(function write(data) {
4    this.emit('data', data)
5    //this.pause() 
6  },
7  function end () { //optional
8    this.emit('end')
9  })

Extended Options

You will probably not need these 99% of the time.

autoDestroy=false

By default, through emits close when the writable and readable side of the stream has ended. If that is not desired, set autoDestroy=false.

1var through = require('through')
2
3//like this
4var ts = through(write, end, {autoDestroy: false})
5//or like this
6var ts = through(write, end)
7ts.autoDestroy = false

License

MIT / Apache2