(fourByteBuf []byte)
| 504 | } |
| 505 | |
| 506 | func (c *rawConnection) readMessage(fourByteBuf []byte) (proto.Message, error) { |
| 507 | hdr, err := c.readHeader(fourByteBuf) |
| 508 | if err != nil { |
| 509 | return nil, err |
| 510 | } |
| 511 | |
| 512 | return c.readMessageAfterHeader(hdr, fourByteBuf) |
| 513 | } |
| 514 | |
| 515 | func (c *rawConnection) readMessageAfterHeader(hdr *bep.Header, fourByteBuf []byte) (proto.Message, error) { |
| 516 | // First comes a 4 byte message length |