MCPcopy
hub / github.com/tinode/chat / asyncRpcLoop

Method asyncRpcLoop

server/cluster.go:104–108  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

102}
103
104func (n *ClusterNode) asyncRpcLoop() {
105 for call := range n.rpcDone {
106 n.handleRpcResponse(call)
107 }
108}
109
110func (n *ClusterNode) p2mSenderLoop() {
111 for req := range n.p2mSender {

Callers 1

startMethod · 0.80

Calls 1

handleRpcResponseMethod · 0.95

Tested by

no test coverage detected