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