MCPcopy
hub / github.com/daptin/daptin / Add

Method Add

server/websockets/websocket_server.go:59–61  ·  view source on GitHub ↗
(c *Client)

Source from the content-addressed store, hash-verified

57}
58
59func (s *Server) Add(c *Client) {
60 s.addCh <- c
61}
62
63func (s *Server) Del(c *Client) {
64 s.delCh <- c

Callers 15

ListenMethod · 0.95
startTransportE2EDaptinFunction · 0.80
nextReqIdFunction · 0.80
dialWSFunction · 0.80
recvJSONFunction · 0.80
tryRecvJSONFunction · 0.80
TestWebSocketManySubscribersFunction · 0.80
TestWebSocketHighThroughputMessagesFunction · 0.80
TestWebSocketConcurrentConnectionsFunction · 0.80
TestWebSocketRapidConnectDisconnectFunction · 0.80
TestWebSocketSlowConsumerDisconnectFunction · 0.80
TestWebSocketConcurrentPublishersFunction · 0.80

Calls

no outgoing calls

Tested by 15

startTransportE2EDaptinFunction · 0.64
nextReqIdFunction · 0.64
dialWSFunction · 0.64
recvJSONFunction · 0.64
tryRecvJSONFunction · 0.64
TestWebSocketManySubscribersFunction · 0.64
TestWebSocketHighThroughputMessagesFunction · 0.64
TestWebSocketConcurrentConnectionsFunction · 0.64
TestWebSocketRapidConnectDisconnectFunction · 0.64
TestWebSocketSlowConsumerDisconnectFunction · 0.64
TestWebSocketConcurrentPublishersFunction · 0.64
TestWebSocketMultiUserMessagingFunction · 0.64