From a454989cf83e62f38b4206e3c9d9a3c110f592b6 Mon Sep 17 00:00:00 2001
From: David Dias <daviddias.p@gmail.com>
Date: Wed, 22 Jul 2015 13:00:10 -0700
Subject: [PATCH] add timed-tape

---
 package.json       |  3 ++-
 tests/base-test.js | 45 +++++++++++++++++++++++++++++++++++++++++++++
 tests/index.js     |  3 +++
 3 files changed, 50 insertions(+), 1 deletion(-)

diff --git a/package.json b/package.json
index acd5e74..8a43fe7 100644
--- a/package.json
+++ b/package.json
@@ -26,6 +26,7 @@
   },
   "homepage": "https://github.com/diasdavid/abstract-stream-muxer",
   "dependencies": {
-    "stream-pair": "^1.0.3"
+    "stream-pair": "^1.0.3",
+    "timed-tape": "^0.1.0"
   }
 }
diff --git a/tests/base-test.js b/tests/base-test.js
index f7cc295..c91b2d5 100644
--- a/tests/base-test.js
+++ b/tests/base-test.js
@@ -80,6 +80,51 @@ module.exports.all = function (test, common) {
     })
   })
 
+  test('Open a stream on one side, write, open a stream in the other side', function (t) {
+    common.setup(test, function (err, Muxer) {
+      t.plan(9)
+      t.ifError(err, 'Should not throw')
+
+      var pair = streamPair.create()
+      var dialer = new Muxer()
+      var listener = new Muxer()
+
+      var connDialer = dialer.attach(pair, false)
+      var connListener = listener.attach(pair.other, true)
+
+      connDialer.dialStream(function (err, stream) {
+        t.ifError(err, 'Should not throw')
+        t.pass('dialed stream from dialer')
+
+        stream.write('hey')
+      })
+
+      connListener.on('stream', function (stream) {
+        t.pass('listener got stream')
+
+        stream.on('data', function (chunk) {
+          t.equal(chunk.toString(), 'hey')
+        })
+
+        connListener.dialStream(function (err, stream) {
+          t.ifError(err, 'Should not throw')
+          t.pass('dialed stream from listener')
+
+          stream.write('hello')
+        })
+
+      })
+
+      connDialer.on('stream', function (stream) {
+        t.pass('dialer got stream')
+
+        stream.on('data', function (chunk) {
+          t.equal(chunk.toString(), 'hello')
+        })
+      })
+    })
+  })
+
   test('Open a stream using the net.connect pattern', function (t) {
     common.setup(test, function (err, Muxer) {
       t.plan(3)
diff --git a/tests/index.js b/tests/index.js
index d146afa..1a1d43b 100644
--- a/tests/index.js
+++ b/tests/index.js
@@ -1,4 +1,7 @@
+var timed = require('timed-tape')
+
 module.exports = function (test, common, mega) {
+  test = timed(test)
   require('./base-test.js').all(test, common)
   require('./stress-test.js').all(test, common)
   if (mega) {