(resp *Response)
| 691 | } |
| 692 | |
| 693 | func (c *rawConnection) handleResponse(resp *Response) { |
| 694 | c.awaitingMut.Lock() |
| 695 | if rc := c.awaiting[resp.ID]; rc != nil { |
| 696 | delete(c.awaiting, resp.ID) |
| 697 | rc <- asyncResult{resp.Data, codeToError(resp.Code)} |
| 698 | close(rc) |
| 699 | } |
| 700 | c.awaitingMut.Unlock() |
| 701 | } |
| 702 | |
| 703 | func (c *rawConnection) send(ctx context.Context, msg proto.Message, done chan struct{}) bool { |
| 704 | select { |
no test coverage detected