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

Method clearPendingRequestCalls

nats.go:5925–5932  ·  view source on GitHub ↗

This will clear any pending Request calls. Lock is assumed to be held by the caller.

()

Source from the content-addressed store, hash-verified

5923// This will clear any pending Request calls.
5924// Lock is assumed to be held by the caller.
5925func (nc *Conn) clearPendingRequestCalls() {
5926 for key, ch := range nc.respMap {
5927 if ch != nil {
5928 close(ch)
5929 delete(nc.respMap, key)
5930 }
5931 }
5932}
5933
5934// Low level close call that will do correct cleanup and set
5935// desired status. Also controls whether user defined callbacks

Callers 2

ForceReconnectMethod · 0.95
closeMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected