Merge pull request #70 from libp2p/open-stream-context

pass contexts to OpenStream in tests

go.mod

@@ -5,10 +5,10 @@ go 1.12
 require (
 	github.com/ipfs/go-log v1.0.4
 	github.com/jbenet/go-temp-err-catcher v0.1.0
-	github.com/libp2p/go-libp2p-core v0.5.5
-	github.com/libp2p/go-libp2p-mplex v0.2.3
+	github.com/libp2p/go-libp2p-core v0.8.0
+	github.com/libp2p/go-libp2p-mplex v0.4.0
 	github.com/libp2p/go-libp2p-pnet v0.2.0
-	github.com/multiformats/go-multiaddr v0.2.1
-	github.com/multiformats/go-multiaddr-net v0.1.5
+	github.com/multiformats/go-multiaddr v0.3.1
+	github.com/multiformats/go-multiaddr-net v0.2.0
 	github.com/stretchr/testify v1.4.0
 )

listener_test.go

 package stream_test
 
 import (
+	"context"
 	"fmt"
 	"io"
 	"sync"
@@ -93,7 +94,7 @@ func TestConnectionsClosedIfNotAccepted(t *testing.T) {
 	errCh := make(chan error)
 	go func() {
 		defer conn.Close()
-		str, err := conn.OpenStream()
+		str, err := conn.OpenStream(context.Background())
 		if err != nil {
 			errCh <- err
 			return

upgrader_test.go

@@ -78,7 +78,7 @@ func testConn(t *testing.T, clientConn, serverConn transport.CapableConn) {
 	t.Helper()
 	require := require.New(t)
 
-	cstr, err := clientConn.OpenStream()
+	cstr, err := clientConn.OpenStream(context.Background())
 	require.NoError(err)
 
 	_, err = cstr.Write([]byte("foobar"))