MCPcopy
hub / github.com/nats-io/nats.go / incrementDeliveredMsgs

Method incrementDeliveredMsgs

jetstream/pull.go:447–449  ·  view source on GitHub ↗

incrementDeliveredMsgs increments delivered message count lock should be held before calling this method

()

Source from the content-addressed store, hash-verified

445// incrementDeliveredMsgs increments delivered message count
446// lock should be held before calling this method
447func (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.

Callers 2

ConsumeMethod · 0.95
NextMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected