MCPcopy Create free account
hub / github.com/coder/coder / rmResponseChan

Method rmResponseChan

vpn/speaker.go:233–237  ·  view source on GitHub ↗
(msgID uint64)

Source from the content-addressed store, hash-verified

231}
232
233func (s *speaker[_, _, _]) rmResponseChan(msgID uint64) {
234 s.mu.Lock()
235 defer s.mu.Unlock()
236 delete(s.responseChans, msgID)
237}
238
239func (s *speaker[_, R, _]) tryToDeliverResponse(resp R) {
240 msgID := resp.GetRpc().GetResponseTo()

Callers 1

unaryRPCMethod · 0.95

Calls 2

LockMethod · 0.45
UnlockMethod · 0.45

Tested by

no test coverage detected