Return io.ErrClosedPipe from closed udpMuxedConn

pion · Apr 30, 2024 · d30f13f · d30f13f
1 parent 75ca3a2
commit d30f13f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/udp_muxed_conn.go b/udp_muxed_conn.go
@@ -77,7 +77,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
@@ -86,7 +86,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
  }
  }
 }