Merge pull request #25 from libp2p/gx/publish-1.7.0

Release 1.7.0

.gx/lastpubver

-1.6.18: QmaijwHnbD4SabGA8C2fN9gchptLvRe2RxqTU5XkjAGBw5
+1.7.0: QmSx9mhEnKWDkgBYaEY6MZFFajUtiQJ8bipSZhzPuALSPv

.travis.yml

@@ -6,7 +6,7 @@ os:
 language: go
 
 go:
-    - 1.7
+    - 1.8
 
 install: true
 

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",
@@ -174,6 +174,6 @@
   "license": "MIT",
   "name": "go-libp2p-swarm",
   "releaseCmd": "git commit -a -m \"gx publish $VERSION\"",
-  "version": "1.6.18"
+  "version": "1.7.0"
 }
 

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),
 	}
 }