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

Method processAsyncInfo

nats.go:4141–4146  ·  view source on GitHub ↗

processAsyncInfo does the same than processInfo, but is called from the parser. Calls processInfo under connection's lock protection.

(info []byte)

Source from the content-addressed store, hash-verified

4139// from the parser. Calls processInfo under connection's lock
4140// protection.
4141func (nc *Conn) processAsyncInfo(info []byte) {
4142 nc.mu.Lock()
4143 // Ignore errors, we will simply not update the server pool...
4144 nc.processInfo(string(info))
4145 nc.mu.Unlock()
4146}
4147
4148// LastError reports the last error encountered via the connection.
4149// It can be used reliably within ClosedCB in order to find out reason

Callers 1

parseMethod · 0.95

Calls 1

processInfoMethod · 0.95

Tested by

no test coverage detected