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

module.exports = function (wrapper) {

require('tape')('simple test', function (a) {

var A = MuxDemux({wrapper: wrapper})
var B = MuxDemux({wrapper: wrapper})

var connected, closed, ended, _hi

B.on('connection', function (hi) {
  _hi = hi
  console.log('CONNECTION')
  a.equal(hi.meta.name, 'hello')
  connected = true
  hi.once('data', function (data) {
    a.equal(data, 'whatever')
  })
})

A.pipe(B).pipe(A)

var hi = A.createStream({name: 'hello'}, {allowHalfOpen: true})

hi.write('whatever')

//A.resume()
//B.resume()

process.nextTick(function () {

  a.ok(connected)

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

  hi.end()
  a.equal(hi.writable, false)
  a.equal(_hi.readable, false)

  _hi.end()
  a.equal(_hi.writable, false)
  a.equal(hi.readable, false)

  hi.on('close', function () { console.log('HI CLOSE') })
  _hi.on('close', function () { console.log('_HI CLOSE') })

  A.end()

  a.ok(closed)
  a.ok(!ended)
  a.end()

})
})

}

if(!module.parent)
  module.exports()