diff --git a/serverconnpublish_test.go b/serverconnpublish_test.go
index 2fa963e6..c1a3bee6 100644
--- a/serverconnpublish_test.go
+++ b/serverconnpublish_test.go
@@ -2,7 +2,6 @@ package gortsplib
 
 import (
 	"bufio"
-	"io"
 	"net"
 	"strconv"
 	"sync/atomic"
@@ -100,11 +99,10 @@ func TestServerConnPublishSetupPath(t *testing.T) {
 					}, nil
 				}
 
-				err = <-conn.Read(ServerConnReadHandlers{
+				<-conn.Read(ServerConnReadHandlers{
 					OnAnnounce: onAnnounce,
 					OnSetup:    onSetup,
 				})
-				require.Equal(t, io.EOF, err)
 			}()
 
 			conn, err := net.Dial("tcp", "localhost:8554")
@@ -466,13 +464,12 @@ func TestServerConnPublishReceivePackets(t *testing.T) {
 					}
 				}
 
-				err = <-conn.Read(ServerConnReadHandlers{
+				<-conn.Read(ServerConnReadHandlers{
 					OnAnnounce: onAnnounce,
 					OnSetup:    onSetup,
 					OnRecord:   onRecord,
 					OnFrame:    onFrame,
 				})
-				require.Equal(t, io.EOF, err)
 			}()
 
 			conn, err := net.Dial("tcp", "localhost:8554")
diff --git a/serverconnread_test.go b/serverconnread_test.go
index 5f7de823..f0c7d099 100644
--- a/serverconnread_test.go
+++ b/serverconnread_test.go
@@ -2,7 +2,6 @@ package gortsplib
 
 import (
 	"bufio"
-	"io"
 	"net"
 	"testing"
 	"time"
@@ -85,10 +84,9 @@ func TestServerConnReadSetupPath(t *testing.T) {
 					}, nil
 				}
 
-				err = <-conn.Read(ServerConnReadHandlers{
+				<-conn.Read(ServerConnReadHandlers{
 					OnSetup: onSetup,
 				})
-				require.Equal(t, io.EOF, err)
 			}()
 
 			conn, err := net.Dial("tcp", "localhost:8554")
@@ -251,12 +249,11 @@ func TestServerConnReadReceivePackets(t *testing.T) {
 					close(packetsReceived)
 				}
 
-				err = <-conn.Read(ServerConnReadHandlers{
+				<-conn.Read(ServerConnReadHandlers{
 					OnSetup: onSetup,
 					OnPlay:  onPlay,
 					OnFrame: onFrame,
 				})
-				require.Equal(t, io.EOF, err)
 			}()
 
 			conn, err := net.Dial("tcp", "localhost:8554")
@@ -390,11 +387,10 @@ func TestServerConnReadTCPResponseBeforeFrames(t *testing.T) {
 			}, nil
 		}
 
-		err = <-conn.Read(ServerConnReadHandlers{
+		<-conn.Read(ServerConnReadHandlers{
 			OnSetup: onSetup,
 			OnPlay:  onPlay,
 		})
-		require.Equal(t, io.EOF, err)
 	}()
 
 	conn, err := net.Dial("tcp", "localhost:8554")
@@ -496,11 +492,10 @@ func TestServerConnReadPlayMultiple(t *testing.T) {
 			}, nil
 		}
 
-		err = <-conn.Read(ServerConnReadHandlers{
+		<-conn.Read(ServerConnReadHandlers{
 			OnSetup: onSetup,
 			OnPlay:  onPlay,
 		})
-		require.Equal(t, io.EOF, err)
 	}()
 
 	conn, err := net.Dial("tcp", "localhost:8554")
@@ -615,12 +610,11 @@ func TestServerConnReadPauseMultiple(t *testing.T) {
 			}, nil
 		}
 
-		err = <-conn.Read(ServerConnReadHandlers{
+		<-conn.Read(ServerConnReadHandlers{
 			OnSetup: onSetup,
 			OnPlay:  onPlay,
 			OnPause: onPause,
 		})
-		require.Equal(t, io.EOF, err)
 	}()
 
 	conn, err := net.Dial("tcp", "localhost:8554")