var stream = require('stream')

var t = stream.Transform({
  transform: function (data, enc, cb) {
    console.log(`transform destroyed=${this._readableState.destroyed}`)
    cb(null)
  },
  flush: function (cb) {
    console.log(`flush destroyed=${this._readableState.destroyed}`)
    cb(null)
  }
})

t.on('close', function () {
  console.log('onclose')
})

t.on('error', function () {
  console.log('onerror')
})

t.on('end', function () {
  console.log('onend')
})

t.on('finish', function () {
  console.log('onfinish')
})

t.resume()
t.write('a')
t.write('b')
t.write('c')
t.destroy(new Error('error'))