(msg P2PMessage)
| 615 | } |
| 616 | |
| 617 | func (c *client) reportMsg(msg P2PMessage) { |
| 618 | select { |
| 619 | case <-c.ctx.Done(): |
| 620 | case c.peerFeed <- msg: |
| 621 | } |
| 622 | } |
| 623 | |
| 624 | //TODO : Move to other module |
| 625 | func (c *client) signFn(msg []byte) (sig []byte, err error) { |