From c130e6e96c931da23fa28b2e1dd5a5002529be69 Mon Sep 17 00:00:00 2001
From: Marten Seemann <martenseemann@gmail.com>
Date: Tue, 26 Apr 2022 14:24:18 +0100
Subject: [PATCH] don't continue on read / write error in stream suite (#59)

---
 p2p/transport/testsuite/stream_suite.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/p2p/transport/testsuite/stream_suite.go b/p2p/transport/testsuite/stream_suite.go
index 8f41a5408d..e7770bfa71 100644
--- a/p2p/transport/testsuite/stream_suite.go
+++ b/p2p/transport/testsuite/stream_suite.go
@@ -141,7 +141,7 @@ func SubtestStress(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr,
 			bufs <- buf
 			if _, err := s.Write(buf); err != nil {
 				t.Errorf("s.Write(buf): %s", err)
-				continue
+				return
 			}
 		}
 	}
@@ -154,10 +154,11 @@ func SubtestStress(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr,
 
 			if _, err := io.ReadFull(s, buf2); err != nil {
 				t.Errorf("io.ReadFull(s, buf2): %s", err)
-				continue
+				return
 			}
 			if !bytes.Equal(buf1, buf2) {
 				t.Errorf("buffers not equal (%x != %x)", buf1[:3], buf2[:3])
+				return
 			}
 		}
 	}