duplex

Simple base class for duplex streams, that automatically handles pausing and buffering.


var duplex = require('duplex')

var d = duplex()
  .on('_data', function (data) {
    d.sendData(data)
  })
  .on('_end', function () {
    d.sendEnd()
  })

API

on('_data', function (data))

Emitted when write(data) is called.

on('_end', function ())

Emitted when end() is called

_data(data)

Add data to the output buffer. 'data' will be emitted if the stream is not paused.

_end()

Cap the output buffer. no more data events may be added. 'end' will be emitted after the buffer drains, or immediately, if the stream is unpaused.

pause()

Pause the readable side of the stream.
This will prevent it from emitting 'data' or or 'end' until resume is called.

resume()

Unpause the readable side of the stream.
This will allow it to emit 'data' and 'end' events.
If there there is any data in the output buffer,
It will start draining immediately.

_pause(), emit('pause')

Pause the writable side of the stream. this will cause write() to return false, so any streams piping into this stream will pause after thier next write.

emit('drain')

Unpause the writable side of the stream. This will cause Stream#pipe to call resume() on any streams piping to this stream.

Automatic Behaviours

destroy() is called automatically after both sides of the stream have ended. write()==false after the stream emits 'pause',
and write()==true after the stream emits 'drain'. The user is responsible for emitting 'pause' and 'drain'.

resume() will be called on nextTick, unless pause() was called manually. If resume() is manually called before the nextTick, the stream will start emitting data immediately.