From e1346da0f150c592a9425ecd8a9ea0e94c595eff Mon Sep 17 00:00:00 2001
From: Friedel Ziegelmayer <dignifiedquire@gmail.com>
Date: Tue, 6 Sep 2016 10:16:25 +0200
Subject: [PATCH] fix(dial-test): ensure goodbye works over tcp

---
 package.json     |  3 ++-
 src/dial-test.js | 26 +++++++++++---------------
 2 files changed, 13 insertions(+), 16 deletions(-)

diff --git a/package.json b/package.json
index 6730920..8e09a1d 100644
--- a/package.json
+++ b/package.json
@@ -38,6 +38,7 @@
     "chai": "^3.5.0",
     "multiaddr": "^2.0.2",
     "pull-goodbye": "0.0.1",
+    "pull-serializer": "^0.3.2",
     "pull-stream": "^3.4.4"
   },
   "contributors": [
@@ -46,4 +47,4 @@
     "Richard Littauer <richard.littauer@gmail.com>",
     "greenkeeperio-bot <support@greenkeeper.io>"
   ]
-}
\ No newline at end of file
+}
diff --git a/src/dial-test.js b/src/dial-test.js
index c4d1d73..8f9d13b 100644
--- a/src/dial-test.js
+++ b/src/dial-test.js
@@ -4,6 +4,7 @@
 const expect = require('chai').expect
 const pull = require('pull-stream')
 const goodbye = require('pull-goodbye')
+const serializer = require('pull-serializer')
 
 module.exports = (common) => {
   describe('dial', () => {
@@ -26,16 +27,7 @@ module.exports = (common) => {
 
     beforeEach((done) => {
       listener = transport.createListener((conn) => {
-        pull(
-          conn,
-          pull.map((x) => {
-            if (x.toString() !== 'GOODBYE') {
-              return new Buffer(x.toString() + '!')
-            }
-            return x
-          }),
-          conn
-        )
+        pull(conn, conn)
       })
       listener.listen(addrs[0], done)
     })
@@ -45,20 +37,24 @@ module.exports = (common) => {
     })
 
     it('simple', (done) => {
-      const s = goodbye({
-        source: pull.values([new Buffer('hey')]),
+      const s = serializer(goodbye({
+        source: pull.values(['hey']),
         sink: pull.collect((err, values) => {
           expect(err).to.not.exist
           expect(
             values
           ).to.be.eql(
-            [new Buffer('hey!')]
+            ['hey']
           )
           done()
         })
-      })
+      }))
 
-      pull(s, transport.dial(addrs[0]), s)
+      pull(
+        s,
+        transport.dial(addrs[0]),
+        s
+      )
     })
 
     it('to non existent listener', (done) => {