Method send

p2p/set.go:294–303

send() sends a message to a specific peer object

(peer *Peer, topic lib.Topic, bz []byte)

// send() sends a message to a specific peer object
func (ps *PeerSet) send(peer *Peer, topic lib.Topic, bz []byte) lib.ErrorI {
	//ps.logger.Debugf("Sending %s message to %s", topic, lib.BytesToTruncatedString(peer.Address.PublicKey))
	go func() {
		ok := peer.conn.Send(topic, bz)
		if !ok {
			ps.logger.Errorf("sending %s message to %s failed", topic, lib.BytesToTruncatedString(peer.Address.PublicKey))
		}
	}()
	return nil
}

// remove() decrements the in/out counters, and deletes it from the set
func (ps *PeerSet) remove(peer *Peer) {