update deps

* Also, make notifications async to prevent them from deadlocking.

package.json

@@ -69,9 +69,9 @@
     },
     {
       "author": "whyrusleeping",
-      "hash": "Qma887khroMXGLJuHLYqqDZXHivAfFPxd2hQ8Z5kucMWTM",
+      "hash": "QmVNPgPmEG4QKaDKkxMPKY34Z53n8efzv1sEh4NTsdhto7",
       "name": "go-peerstream",
-      "version": "1.6.2"
+      "version": "1.7.0"
     },
     {
       "author": "whyrusleeping",
@@ -81,9 +81,9 @@
     },
     {
       "author": "whyrusleeping",
-      "hash": "QmaDBnCnmwPdqWGCJRLnmkfXRTEHp5rt3248Bwk4A7fLvt",
+      "hash": "QmPqPjFBqpx5AEfWYDJqt8w8YhRgPn7jw52omCKrYue4B6",
       "name": "go-libp2p-conn",
-      "version": "1.6.4"
+      "version": "1.6.5"
     },
     {
       "author": "whyrusleeping",
@@ -117,9 +117,9 @@
     },
     {
       "author": "whyrusleeping",
-      "hash": "QmR1fAHJvEyYFdEGn5jVmU4NL5kNSVJ48cduXB2whWbJq2",
+      "hash": "Qmcx4KoZ91XS6izLjdkujAMAunAS1YuTgfgASgYaZF5GkR",
       "name": "go-addr-util",
-      "version": "1.1.7"
+      "version": "1.2.0"
     },
     {
       "hash": "QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52",

swarm_notif_test.go

@@ -17,8 +17,10 @@ func streamsSame(a, b inet.Stream) bool {
 }
 
 func TestNotifications(t *testing.T) {
+	const swarmSize = 5
+
 	ctx := context.Background()
-	swarms := makeSwarms(ctx, t, 5)
+	swarms := makeSwarms(ctx, t, swarmSize)
 	defer func() {
 		for _, s := range swarms {
 			s.Close()
@@ -30,7 +32,7 @@ func TestNotifications(t *testing.T) {
 	// signup notifs
 	notifiees := make([]*netNotifiee, len(swarms))
 	for i, swarm := range swarms {
-		n := newNetNotifiee()
+		n := newNetNotifiee(swarmSize)
 		swarm.Notify(n)
 		notifiees[i] = n
 	}
@@ -184,14 +186,14 @@ type netNotifiee struct {
 	closedStream chan inet.Stream
 }
 
-func newNetNotifiee() *netNotifiee {
+func newNetNotifiee(buffer int) *netNotifiee {
 	return &netNotifiee{
-		listen:       make(chan ma.Multiaddr),
-		listenClose:  make(chan ma.Multiaddr),
-		connected:    make(chan inet.Conn),
-		disconnected: make(chan inet.Conn),
-		openedStream: make(chan inet.Stream),
-		closedStream: make(chan inet.Stream),
+		listen:       make(chan ma.Multiaddr, buffer),
+		listenClose:  make(chan ma.Multiaddr, buffer),
+		connected:    make(chan inet.Conn, buffer),
+		disconnected: make(chan inet.Conn, buffer),
+		openedStream: make(chan inet.Stream, buffer),
+		closedStream: make(chan inet.Stream, buffer),
 	}
 }