why am i getting a varint error

1 files changed, 3 insertions, 7 deletions

diff --git a/azalea-buf/src/read.rs b/azalea-buf/src/read.rs
index 045dcd4f..78c858e4 100644
--- a/azalea-buf/src/read.rs
+++ b/azalea-buf/src/read.rs
@@ -64,13 +64,10 @@ pub async fn read_varint_async(
     let mut buffer = [0];
     let mut ans = 0;
     for i in 0..5 {
-        reader
-            .read_exact(&mut buffer)
-            .await
-            .map_err(|_| BufReadError::InvalidVarInt)?;
+        reader.read_exact(&mut buffer).await?;
         ans |= ((buffer[0] & 0b0111_1111) as i32) << (7 * i);
         if buffer[0] & 0b1000_0000 == 0 {
-            return Ok(ans);
+            break;
         }
     }
     Ok(ans)
@@ -103,8 +100,7 @@ impl McBufVarReadable for i32 {
         let mut buffer = [0];
         let mut ans = 0;
         for i in 0..5 {
-            buf.read_exact(&mut buffer)
-                .map_err(|_| BufReadError::InvalidVarInt)?;
+            buf.read_exact(&mut buffer)?;
             ans |= ((buffer[0] & 0b0111_1111) as i32) << (7 * i);
             if buffer[0] & 0b1000_0000 == 0 {
                 break;