feat: update to go-libp2p-core 0.7.0

Updates stream interfaces.

go.mod

@@ -3,7 +3,8 @@ module github.com/libp2p/go-libp2p-testing
 go 1.12
 
 require (
-	github.com/libp2p/go-libp2p-core v0.3.0
-	github.com/multiformats/go-multiaddr v0.2.0
-	google.golang.org/grpc v1.20.1
+	github.com/libp2p/go-libp2p-core v0.7.0
+	github.com/multiformats/go-multiaddr v0.3.1
+	go.uber.org/atomic v1.6.0
+	google.golang.org/grpc v1.31.1
 )

suites/mux/muxer_suite.go

@@ -320,12 +320,13 @@ func tcpPipe(t *testing.T) (net.Conn, net.Conn) {
 
 func SubtestStreamOpenStress(t *testing.T, tr mux.Multiplexer) {
 	wg := new(sync.WaitGroup)
-	defer wg.Wait()
 
 	a, b := tcpPipe(t)
 	defer a.Close()
 	defer b.Close()
 
+	defer wg.Wait()
+
 	wg.Add(1)
 	count := 10000
 	workers := 5
@@ -343,7 +344,17 @@ func SubtestStreamOpenStress(t *testing.T, tr mux.Multiplexer) {
 					t.Error(err)
 					return
 				}
-				s.Close()
+				err = s.CloseWrite()
+				if err != nil {
+					t.Error(err)
+				}
+				n, err := s.Read([]byte{0})
+				if n != 0 {
+					t.Error("expected to read no bytes")
+				}
+				if err != io.EOF {
+					t.Errorf("expected an EOF, got %s", err)
+				}
 			}
 		}
 
@@ -364,7 +375,7 @@ func SubtestStreamOpenStress(t *testing.T, tr mux.Multiplexer) {
 	recv := make(chan struct{}, count*workers)
 	go func() {
 		defer wg.Done()
-		for {
+		for i := 0; i < count*workers; i++ {
 			str, err := muxb.AcceptStream()
 			if err != nil {
 				break