Return io.ErrClosedPipe from closed udpMuxedConn

pion · Apr 30, 2024 · 51293a0 · 51293a0
1 parent 89d2c47
commit 51293a0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/udp_muxed_conn.go b/udp_muxed_conn.go
@@ -88,7 +88,7 @@ func (c *udpMuxedConn) ReadFrom(b []byte) (n int, rAddr net.Addr, err error) {
 
 		if c.state == udpMuxedConnClosed {
 			c.mu.Unlock()
-			return 0, nil, io.EOF
+			return 0, nil, io.ErrClosedPipe
 		}
 
 		c.state = udpMuxedConnWaiting
@@ -97,7 +97,7 @@ func (c *udpMuxedConn) ReadFrom(b []byte) (n int, rAddr net.Addr, err error) {
 		select {
 		case <-c.notify:
 		case <-c.closedChan:
-			return 0, nil, io.EOF
+			return 0, nil, io.ErrClosedPipe
 		}
 	}
 }