/*
  connect two streams.

  on a disconnect, both streams should emit 'close'
*/

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

module.exports = function (wrapper) {

test('disconnect 2', function (a) {
console.log('disconnect2')

  var client = MuxDemux({error: true, wrapper: wrapper})
  var server = MuxDemux({error: true, wrapper: wrapper})

  client.pipe(server).pipe(client)
//  server.pipe(process.stderr, {end: false})
  var randoms = []
  function rand() {
    var r
    randoms.push(r = Math.random())
    return r
  }
  var streams = 0
  server.on('connection', function (s) {
    console.log('CONNECTION!!!')
    s.write(rand())
    s.write(rand())
    s.write(rand())
    s.write(rand())
    console.log('END')    
    try {
      s.end()
    } catch (err) {
      console.error('END THREW')
      throw err
    }
    console.log('ENDED')    
  })

  c = client.createStream()
  c.on('data', function (data) {
    var r 
    a.equal(data, r = randoms.shift())
    console.log('data>>', r)
  })
  .on('end', function () {
    console.log('end>>')
    a.end()
  })

//  c.pipe(process.stderr, {end: false})

});

}

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