X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=r.go;h=098ee49be485cb37a10e420c5fce7c03c6405a5d;hb=8fa6c4b0000e2dc27fce9220db1a5eb8bf468e81;hp=9b8f51069e541d86986497e383dec57349f563b8;hpb=e81a692325b0d36a34fa521847dd38f22433cbb8;p=netstring.git

diff --git a/r.go b/r.go
index 9b8f510..098ee49 100644
--- a/r.go
+++ b/r.go
@@ -58,7 +58,13 @@ func (r *Reader) Next() (uint64, error) {
 	}
 	r.left = size
 	r.eof = false
-	return size, nil
+	if r.left == 0 {
+		err = r.checkTerminator()
+		if err == nil {
+			r.eof = true
+		}
+	}
+	return size, err
 }
 
 func (r *Reader) checkTerminator() error {