r.go | 9 +++++---- diff --git a/r.go b/r.go index 6789d4fc89f7b6e28e1835a9c135329a6765ad4f91eb1e6147d2c1b53bd3e9d2..5201abe7e3363c95b6d76e71a00346ed4b0c0933ced908370538ae5c09e729f5 100644 --- a/r.go +++ b/r.go @@ -20,6 +20,7 @@ import ( "bufio" "errors" + "fmt" "io" "strconv" ) @@ -45,11 +46,11 @@ return 0, errors.New("current chunk is unread") } lenRaw, err := r.r.ReadSlice(':') if err != nil { - return 0, err + return 0, fmt.Errorf("netstring header: %w", err) } size, err := strconv.ParseUint(string(lenRaw[:len(lenRaw)-1]), 10, 64) if err != nil { - return 0, err + return 0, fmt.Errorf("netstring header: %w", err) } r.left = size r.eof = false @@ -59,10 +60,10 @@ func (r *Reader) checkTerminator() error { b, err := r.r.ReadByte() if err != nil { - return err + return fmt.Errorf("netstring terminator: %w", err) } if b != ',' { - return errors.New("no terminator found") + return errors.New("netstring terminator: not found") } return nil }