cleanups

centrifugal · May 12, 2024 · 10379b5 · 10379b5
1 parent 240e132
commit 10379b5
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/client.go b/client.go
@@ -3197,14 +3197,13 @@ func (c *Client) writePublication(ch string, pub *protocol.Publication, prep pre
 
  if deltaAllowed {
  return c.transportEnqueue(prep.localDeltaData, ch, protocol.FrameTypePushPublication)
- } else {
- c.mu.Lock()
- if chCtx, chCtxOK := c.channels[ch]; chCtxOK {
- chCtx.flags |= flagDeltaAllowed
- c.channels[ch] = chCtx
- }
- c.mu.Unlock()
  }
+ c.mu.Lock()
+ if chCtx, chCtxOK := c.channels[ch]; chCtxOK {
+ chCtx.flags |= flagDeltaAllowed
+ c.channels[ch] = chCtx
+ }
+ c.mu.Unlock()
  }
  return c.transportEnqueue(prep.fullData, ch, protocol.FrameTypePushPublication)
  }