diff --git a/message.go b/message.go index 6871ce6..bc68fff 100644 --- a/message.go +++ b/message.go @@ -57,3 +57,12 @@ func (msg *Message) Read(p []byte) (int, error) { msg.Body = msg.Body[n:] return n, nil } + +func (msg *Message) ReadByte() (byte, error) { + if len(msg.Body) == 0 { + return 0, io.EOF + } + n := msg.Body[0] + msg.Body = msg.Body[1:] + return n, nil +}