diff --git a/subscriber.go b/subscriber.go
index 9931060..8315cbc 100644
--- a/subscriber.go
+++ b/subscriber.go
@@ -235,7 +235,7 @@ func (suber *WebRTCSubscriber) OnEvent(event any) {
 						suber.PeerConnection.Close()
 					}()
 				}
-			case PeerConnectionStateDisconnected, PeerConnectionStateFailed:
+			case PeerConnectionStateDisconnected, PeerConnectionStateFailed, PeerConnectionStateClosed:
 				suber.Stop(zap.String("reason", pcs.String()))
 			}
 		})