chore: update deps, clean examples

examples/dialer.js

@@ -5,13 +5,21 @@ const pull = require('pull-stream')
 const toPull = require('stream-to-pull-stream')
 const libp2pSPDY = require('../src')
 
+// const socket = tcp.connect(9999, '10.0.1.12')
 const socket = tcp.connect(9999)
+
 const muxer = libp2pSPDY.dialer(toPull(socket))
 
+/*
 muxer.on('stream', (stream) => {
   console.log('-> got new muxed stream')
-  pull(stream, pull.log, stream)
+  pull(
+    stream,
+    pull.log,
+    stream
+  )
 })
+*/
 
 console.log('-> opening a stream from my side')
 const stream = muxer.newStream((err) => {

examples/listener.js

@@ -11,16 +11,16 @@ const listener = tcp.createServer((socket) => {
   const muxer = libp2pSPDY.listener(toPull(socket))
 
   muxer.on('stream', (stream) => {
-    console.log('-> got new muxed stream')
+    console.log('INCOMMING MUXED STREAM')
     pull(
       stream,
-      pull.through((data) => {
+      pull.drain((data) => {
         console.log('DO I GET DATA?', data)
-      }),
-      stream
+      })
     )
   })
 
+  /*
   console.log('-> opening a stream from my side')
   const stream = muxer.newStream((err) => {
     if (err) throw err
@@ -31,6 +31,7 @@ const listener = tcp.createServer((socket) => {
     pull.values(['hey, how is it going']),
     stream
   )
+  */
 })
 
 listener.listen(9999, () => {

package.json

@@ -45,7 +45,6 @@
     "pull-pair": "^1.1.0",
     "pull-stream": "^3.4.3",
     "run-parallel": "^1.1.6",
-    "stream-to-pull-stream": "^1.7.0",
     "tap-spec": "^4.1.1",
     "tape": "^4.2.0"
   },
@@ -65,4 +64,4 @@
     "greenkeeperio-bot <support@greenkeeper.io>",
     "nginnever <ginneversource@gmail.com>"
   ]
-}
+}

src/muxer.js

@@ -48,7 +48,6 @@ module.exports = class Muxer extends EventEmitter {
       headers: {}
     }, (err, stream) => {
       conn.setInnerConn(toPull.duplex(stream), this.conn)
-
       callback(err, conn)
     })