remove error handler when a record received (#73)

reductstore · Oct 29, 2023 · 228e7dc · 228e7dc
1 parent d37b6b5
commit 228e7dc
Showing 1 changed file with 5 additions and 3 deletions.
diff --git 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);
                     });
 
                 }