Fix unreachable conditional (#656)

ionorg · Jul 11, 2022 · 7b6cc7b · 7b6cc7b
1 parent 68545cc
commit 7b6cc7b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/sfu/receiver.go b/pkg/sfu/receiver.go
@@ -370,7 +370,7 @@ func (w *WebRTCReceiver) writeRTP(layer int) {
 
 		for _, dt := range w.downTracks[layer].Load().([]*DownTrack) {
 			if err = dt.WriteRTP(pkt, layer); err != nil {
-				if err == io.EOF && err == io.ErrClosedPipe {
+				if err == io.EOF || err == io.ErrClosedPipe {
 					w.Lock()
 					w.deleteDownTrack(layer, dt.id)
 					w.Unlock()