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

Method changeSubStatus

nats.go:5163–5169  ·  view source on GitHub ↗

changeSubStatus changes subscription status and sends events to all listeners. Lock should be held entering.

(status SubStatus)

Source from the content-addressed store, hash-verified

5161// changeSubStatus changes subscription status and sends events
5162// to all listeners. Lock should be held entering.
5163func (s *Subscription) changeSubStatus(status SubStatus) {
5164 if s == nil {
5165 return
5166 }
5167 s.sendStatusEvent(status)
5168 s.status = status
5169}
5170
5171// Unsubscribe will remove interest in the given subject.
5172//

Callers 5

subscribeLockedMethod · 0.95
validateNextMsgStateMethod · 0.95
processMsgMethod · 0.80
removeSubMethod · 0.80
unsubscribeMethod · 0.80

Calls 1

sendStatusEventMethod · 0.95

Tested by

no test coverage detected