//var a = require('assertions')
var es = require('event-stream')
var MuxDemux = require('../')
var test = require('tape')

test('test close', function (a) {

  var mx = MuxDemux(), ended = false, callback = false

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

  mx.close(function () {
    callback = true
  }) //end the mx stream after the sub-streams close.

  var A = mx.createStream()
  var B = mx.createStream()
  var C = mx.createStream()

  a.equal(ended, false)

  A.end()
  B.end()

  a.equal(ended, false)
  a.equal(callback, false)

  C.end()

  process.nextTick(function () {
    a.equal(ended, true)
    a.equal(callback, true)
    a.end()
  })
})