Method send

p2p/client.go:206–216

(req p2pRequest)

}

func (c *client) send(req p2pRequest) {
	go func() {
		select {
		case <-c.ctx.Done():
		default:
			if err := req.sendReq(c.peerSend); err != nil {
				req.replyResult(nil, errors.Errorf("client send: %w", err))
			}
		}
	}()
}

func (c *client) encryptPipe(plaintext chan []byte) (out chan []byte) {
	out = make(chan []byte)