diff --git a/src/Bucket.ts b/src/Bucket.ts
index 7fe9993..e2e5162 100644
--- a/src/Bucket.ts
+++ b/src/Bucket.ts
@@ -338,17 +338,19 @@ export class Bucket {
                 let buffer = Buffer.from([]);
                 if (!head) {
                     buffer = await new Promise((resolve, reject) => {
+                        const err_handler = (err: any) => {
+                            reject(err);
+                        };
                         data.on("readable", function handler() {
                             const chunk = data.read(Number(size));
                             if (chunk !== null) {
                                 resolve(chunk);
                                 data.off("readable", handler);
+                                data.off("error", err_handler);
                             }
                         });
 
-                        data.on("error", (err: any) => {
-                            reject(err);
-                        });
+                        data.on("error", err_handler);
                     });
 
                 }