From: Sergey Matveev Date: Fri, 20 Jan 2023 07:54:14 +0000 (+0300) Subject: Simplify :-finding X-Git-Tag: v2.3.0~1 X-Git-Url: http://www.git.cypherpunks.ru/?p=netstring.git;a=commitdiff_plain;h=3a61c7072642334ab9aa738230063811cba8db25 Simplify :-finding --- diff --git a/r.go b/r.go index 7a6d284..68a93ca 100644 --- a/r.go +++ b/r.go @@ -19,7 +19,6 @@ package netstring import ( "bufio" - "bytes" "errors" "io" "strconv" @@ -44,19 +43,12 @@ func (r *Reader) Next() (uint64, error) { if !r.eof { return 0, errors.New("current chunk is unread") } - p, _ := r.r.Peek(21) - if len(p) == 0 { - return 0, io.EOF - } - idx := bytes.IndexByte(p, ':') - if idx == -1 { - return 0, errors.New("no length separator found") - } - size, err := strconv.ParseUint(string(p[:idx]), 10, 64) + lenRaw, err := r.r.ReadSlice(':') if err != nil { return 0, err } - if _, err = r.r.Discard(idx + 1); err != nil { + size, err := strconv.ParseUint(string(lenRaw[:len(lenRaw)-1]), 10, 64) + if err != nil { return 0, err } r.left = size