pex_reactor.go
func DecodeMessage(bz []byte) (msgType byte, msg PexMessage, err error) {
	msgType = bz[0]
	n := new(int)
	r := bytes.NewReader(bz)
	msg = wire.ReadBinary(struct{ PexMessage }{}, r, maxPexMessageSize, n, &err).(struct{ PexMessage }).PexMessage
	return
}
func DecodeMessage(bz []byte) (msgType byte, msg PexMessage, err error) {
	msgType = bz[0]
	n := new(int)
	r := bytes.NewReader(bz)
	msg = wire.ReadBinary(struct{ PexMessage }{}, r, maxPexMessageSize, n, &err).(struct{ PexMessage }).PexMessage
	return
}
func DecodeMessage ( bz [ ] byte ) ( msgType byte , msg PexMessage , err error ) { msgType = bz [ 0 ] n := new ( int ) r := bytes . NewReader ( bz ) msg = wire . ReadBinary ( struct { PexMessage } { } , r , maxPexMessageSize , n , & err ) . ( struct { PexMessage } ) . PexMessage return }
// DecodeMessage implements interface registered above.
DecodeMessage implements interface registered above .