chore: address review

package.json

@@ -33,7 +33,9 @@
     "chai": "^4.2.0",
     "dirty-chai": "^2.0.1",
     "it-pair": "^1.0.0",
-    "multiaddr": "^7.3.0"
+    "it-pipe": "^1.1.0",
+    "multiaddr": "^7.3.0",
+    "streaming-iterables": "^4.1.2"
   },
   "dependencies": {
     "abortable-iterator": "^3.0.0",

test/stream-to-ma-conn.spec.js

@@ -7,6 +7,8 @@ const expect = chai.expect
 chai.use(dirtyChai)
 
 const pair = require('it-pair')
+const pipe = require('it-pipe')
+const { collect } = require('streaming-iterables')
 const multiaddr = require('multiaddr')
 
 const streamToMaConn = require('../src/stream-to-ma-conn')
@@ -35,4 +37,20 @@ describe('Convert stream into a multiaddr connection', () => {
     maConn.close()
     expect(maConn.timeline.close).to.exist()
   })
+
+  it('can stream data over the multiaddr connection', async () => {
+    const stream = pair()
+    const maConn = streamToMaConn({ stream })
+
+    const data = 'hey'
+    const streamData = await pipe(
+      [data],
+      maConn,
+      collect
+    )
+
+    expect(streamData).to.eql([data])
+    // underlying stream end closes the connection
+    expect(maConn.timeline.close).to.exist()
+  })
 })