var MuxDemux = require('../')
  var through  = require('event-stream').through
  
  //make a through stream that is delayed by one tick
  
  require('tape')(function (t) {
  
  function tick () {
    var stream
    return stream = through(function (data) {
      process.nextTick(function () {
        stream.emit('data', data)
      })
    }, function () {
      process.nextTick(function () {
        stream.emit('end', data)
      })
    })
  }
  
  var A = MuxDemux()
  var B = MuxDemux()
  
  var errored = false
  
  A.pipe(tick()).pipe(B).pipe(tick()).pipe(A)
  
  var a = A.createStream('test')
    .on('error', function (err) {
      errored = true
      console.log('expected error:', err.message)
      t.notEqual(err, null, 'expected an error')
      t.end()
    })
  
  })