diff --git a/mixing/mixclient/client.go b/mixing/mixclient/client.go
index 06fecea9d..3b0d02449 100644
--- a/mixing/mixclient/client.go
+++ b/mixing/mixclient/client.go
@@ -446,7 +446,7 @@ func (c *Client) sendLocalPeerMsgs(ctx context.Context, s *sessionRun, m func(p
 
 	now := time.Now()
 	for _, p := range s.peers {
-		if p.remote {
+		if p.remote || p.ctx.Err() != nil {
 			continue
 		}
 		msg := m(p)