decrementPendingMsgs decrements pending message count and byte count lock should be held before calling this method
(msg *nats.Msg)
| 436 | // decrementPendingMsgs decrements pending message count and byte count |
| 437 | // lock should be held before calling this method |
| 438 | func (s *pullSubscription) decrementPendingMsgs(msg *nats.Msg) { |
| 439 | s.pending.msgCount-- |
| 440 | if s.consumeOpts.MaxBytes != 0 && !s.consumeOpts.LimitSize { |
| 441 | s.pending.byteCount -= msg.Size() |
| 442 | } |
| 443 | } |
| 444 | |
| 445 | // incrementDeliveredMsgs increments delivered message count |
| 446 | // lock should be held before calling this method |