diff --git a/app/src/main/java/com/nextcloud/talk/activities/CallActivity.java b/app/src/main/java/com/nextcloud/talk/activities/CallActivity.java
index 343111e8d..f342be713 100644
--- a/app/src/main/java/com/nextcloud/talk/activities/CallActivity.java
+++ b/app/src/main/java/com/nextcloud/talk/activities/CallActivity.java
@@ -1971,7 +1971,7 @@ public class CallActivity extends CallBaseActivity {
             peerConnectionWrapperList.add(peerConnectionWrapper);
 
             PeerConnectionWrapper.PeerConnectionObserver peerConnectionObserver =
-                new CallActivityPeerConnectionObserver(sessionId, type);
+                new CallActivityPeerConnectionObserver(sessionId);
             peerConnectionObservers.put(sessionId + "-" + type, peerConnectionObserver);
             peerConnectionWrapper.addObserver(peerConnectionObserver);
 
@@ -2566,11 +2566,9 @@ public class CallActivity extends CallBaseActivity {
     private class CallActivityPeerConnectionObserver implements PeerConnectionWrapper.PeerConnectionObserver {
 
         private final String sessionId;
-        private final String videoStreamType;
 
-        private CallActivityPeerConnectionObserver(String sessionId, String videoStreamType) {
+        private CallActivityPeerConnectionObserver(String sessionId) {
             this.sessionId = sessionId;
-            this.videoStreamType = videoStreamType;
         }
 
         @Override
@@ -2588,12 +2586,6 @@ public class CallActivity extends CallBaseActivity {
                     updateSelfVideoViewIceConnectionState(iceConnectionState);
                 }
 
-                if (iceConnectionState == PeerConnection.IceConnectionState.CLOSED) {
-                    endPeerConnection(sessionId, VIDEO_STREAM_TYPE_SCREEN.equals(videoStreamType));
-
-                    return;
-                }
-
                 if (iceConnectionState == PeerConnection.IceConnectionState.FAILED) {
                     if (webSocketClient != null && webSocketClient.getSessionId() != null && webSocketClient.getSessionId().equals(sessionId)) {
                         setCallState(CallStatus.PUBLISHER_FAILED);