Merge pull request #23 from libp2p/feat/remove-chan

remove "Chan" type
libp2p · Aug 5, 2021 · 453c310 · 453c310
2 parents 7083218 + e20bcc3
commit 453c310
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 224 deletions.
diff --git a/chan.go b/chan.go
diff --git a/chan_test.go b/chan_test.go
diff --git a/limit_test.go b/limit_test.go
@@ -22,4 +22,7 @@ func TestLimitWriter(t *testing.T) {
 		t.Fatal("Expected to write 3 bytes with no errors")
 	}
 	err = writer.Flush()
+	if err != nil {
+		t.Fatal(err)
+	}
 }
diff --git a/msgio_test.go b/msgio_test.go
@@ -12,6 +12,12 @@ import (
 	"time"
 )
 
+func randBuf(r *rand.Rand, size int) []byte {
+	buf := make([]byte, size)
+	_, _ = r.Read(buf)
+	return buf
+}
+
 func TestReadWrite(t *testing.T) {
 	buf := bytes.NewBuffer(nil)
 	writer := NewWriter(buf)
@@ -54,8 +60,7 @@ type testIoReadWriter struct {
 
 func TestReadWriterClose(t *testing.T) {
 	r, w := io.Pipe()
-	var rw ReadWriteCloser
-	rw = NewReadWriter(testIoReadWriter{r, w})
+	rw := NewReadWriter(testIoReadWriter{r, w})
 	SubtestReaderWriterClose(t, rw)
 }