var MuxDemux = require('../')

require('tape')('end kills all streams', function (t) {
  var ended = false, closed = false
  var mx1 = MuxDemux()
  var mx2 = MuxDemux()

  var s = mx1.createStream()

  mx1.pipe(mx2).pipe(mx1)

  mx1.on('end', function () {
    ended = true
  })

  mx1.on('close', function () {
    closed = true
  })

  mx1.resume()
  mx1.end()

  process.nextTick(function () {
    t.equal(closed, true)
    t.equal(ended, true)
    t.end()
  })

})