fix transport integration test

libp2p · Mar 6, 2024 · 6fb4c40 · 6fb4c40
1 parent 3832d79
commit 6fb4c40
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/p2p/test/transport/transport_test.go b/p2p/test/transport/transport_test.go
@@ -327,6 +327,10 @@ func TestManyStreams(t *testing.T) {
 			h1.SetStreamHandler("echo", func(s network.Stream) {
 				io.Copy(s, s)
 				s.CloseWrite()
+				// Users do need to call Close or Reset after CloseRead and CloseWrite
+				// For webRTC streams it is necessary that Close be called for datachannel
+				// cleanup
+				s.Close()
 			})
 
 			streams := make([]network.Stream, streamCount)