()
| 194 | } |
| 195 | |
| 196 | func (c *client) close() (err error) { |
| 197 | c.cancel() |
| 198 | err = c.conn.Close() |
| 199 | if err != nil { |
| 200 | err = errors.Errorf("client close: %w", err) |
| 201 | } |
| 202 | <-c.ctx.Done() |
| 203 | return |
| 204 | } |
| 205 | |
| 206 | func (c *client) send(req p2pRequest) { |
| 207 | go func() { |
no test coverage detected