@@ -114,7 +113,9 @@ func (e *EchoProtocol) onEchoResponse(s inet.Stream) {
...
@@ -114,7 +113,9 @@ func (e *EchoProtocol) onEchoResponse(s inet.Stream) {
return
return
}
}
assert.True(req.Message==data.Message,nil,"Expected echo to respond with request message")
ifreq.Message!=data.Message{
log.Fatalln("Expected echo to respond with request message")
}
log.Printf("%s: Received echo response from %s. Message id:%s. Message: %s.",s.Conn().LocalPeer(),s.Conn().RemotePeer(),data.MessageData.Id,data.Message)
log.Printf("%s: Received echo response from %s. Message id:%s. Message: %s.",s.Conn().LocalPeer(),s.Conn().RemotePeer(),data.MessageData.Id,data.Message)