diff --git a/app/proxyman/mux/mux.go b/app/proxyman/mux/mux.go
index 02ede2963..9677991af 100644
--- a/app/proxyman/mux/mux.go
+++ b/app/proxyman/mux/mux.go
@@ -42,7 +42,7 @@ func (s *session) closeUplink() {
 	allDone = s.uplinkClosed && s.downlinkClosed
 	s.Unlock()
 	if allDone {
-		s.parent.remove(s.id)
+		go s.parent.remove(s.id)
 	}
 }
 
@@ -53,7 +53,7 @@ func (s *session) closeDownlink() {
 	allDone = s.uplinkClosed && s.downlinkClosed
 	s.Unlock()
 	if allDone {
-		s.parent.remove(s.id)
+		go s.parent.remove(s.id)
 	}
 }
 
@@ -279,6 +279,15 @@ func (m *Client) fetchOutput() {
 			break
 		}
 	}
+
+	// Close all downlinks
+	m.access.RLock()
+	for _, s := range m.sessions {
+		s.closeUplink()
+		s.closeDownlink()
+		s.output.CloseError()
+	}
+	m.access.RUnlock()
 }
 
 type Server struct {