This will clear any pending Request calls. Lock is assumed to be held by the caller.
()
| 5923 | // This will clear any pending Request calls. |
| 5924 | // Lock is assumed to be held by the caller. |
| 5925 | func (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 |
no outgoing calls
no test coverage detected