()
| 221 | } |
| 222 | |
| 223 | func (s *speaker[_, R, _]) newRPC() (uint64, chan R) { |
| 224 | s.mu.Lock() |
| 225 | defer s.mu.Unlock() |
| 226 | msgID := s.nextMsgID |
| 227 | s.nextMsgID++ |
| 228 | c := make(chan R) |
| 229 | s.responseChans[msgID] = c |
| 230 | return msgID, c |
| 231 | } |
| 232 | |
| 233 | func (s *speaker[_, _, _]) rmResponseChan(msgID uint64) { |
| 234 | s.mu.Lock() |