incrementDeliveredMsgs increments delivered message count lock should be held before calling this method
()
| 445 | // incrementDeliveredMsgs increments delivered message count |
| 446 | // lock should be held before calling this method |
| 447 | func (s *pullSubscription) incrementDeliveredMsgs() { |
| 448 | s.delivered++ |
| 449 | } |
| 450 | |
| 451 | // checkPending verifies whether there are enough messages in |
| 452 | // the buffer to trigger a new pull request. |