diff --git a/.gx/lastpubver b/.gx/lastpubver
index afa7391..3d9204e 100644
--- a/.gx/lastpubver
+++ b/.gx/lastpubver
@@ -1 +1 @@
-0.8.16: QmatoKaefBS5hopnDyMqZUgCjbBRPEi4ktZP5FVruiczbB
+0.8.17: QmYFCNMYp7fR9p2pHDXPGtawfoAYEwrR9GLQbihkB96Krs
diff --git a/.travis.yml b/.travis.yml
index 008af4e..46392bd 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -4,7 +4,7 @@ os:
 language: go
 
 go:
-    - 1.7
+    - 1.8
 
 install: true
 
diff --git a/notify.go b/notify.go
index 5d94878..fdcaf39 100644
--- a/notify.go
+++ b/notify.go
@@ -1,8 +1,6 @@
 package floodsub
 
 import (
-	"context"
-
 	inet "github.com/libp2p/go-libp2p-net"
 	ma "github.com/multiformats/go-multiaddr"
 )
@@ -18,17 +16,19 @@ func (p *PubSubNotif) ClosedStream(n inet.Network, s inet.Stream) {
 }
 
 func (p *PubSubNotif) Connected(n inet.Network, c inet.Conn) {
-	s, err := p.host.NewStream(context.Background(), c.RemotePeer(), ID)
-	if err != nil {
-		log.Warning("opening new stream to peer: ", err, c.LocalPeer(), c.RemotePeer())
-		return
-	}
+	go func() {
+		s, err := p.host.NewStream(p.ctx, c.RemotePeer(), ID)
+		if err != nil {
+			log.Warning("opening new stream to peer: ", err, c.LocalPeer(), c.RemotePeer())
+			return
+		}
 
-	select {
-	case p.newPeers <- s:
-	case <-p.ctx.Done():
-		s.Close()
-	}
+		select {
+		case p.newPeers <- s:
+		case <-p.ctx.Done():
+			s.Close()
+		}
+	}()
 }
 
 func (p *PubSubNotif) Disconnected(n inet.Network, c inet.Conn) {
diff --git a/package.json b/package.json
index a6d07a0..2981b21 100644
--- a/package.json
+++ b/package.json
@@ -72,6 +72,6 @@
   "license": "",
   "name": "floodsub",
   "releaseCmd": "git commit -a -m \"gx publish $VERSION\"",
-  "version": "0.8.16"
+  "version": "0.8.17"
 }