fix the same issue in read

googleapis · Jan 12, 2022 · a297a78 · a297a78
1 parent 2fc0887
commit a297a78
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 5 deletions.
diff --git a/src/table.ts b/src/table.ts
@@ -905,8 +905,6 @@ Please use the format 'prezzy' or '${instance.name}/tables/prezzy'.`);
 
       activeRequestStream = requestStream!;
 
-      requestStream!.on('request', () => numRequestsMade++);
-
       const toRowStream = new Transform({
         transform: (rowData, _, next) => {
           if (
@@ -945,6 +943,7 @@ Please use the format 'prezzy' or '${instance.name}/tables/prezzy'.`);
         }
       });
       rowStream.pipe(userStream);
+      numRequestsMade++;
     };
 
     makeNewRequest();

diff --git a/test/table.ts b/test/table.ts
@@ -1187,7 +1187,6 @@ describe('Bigtable/Table', () => {
           (stream as any).abort = () => {};
 
           setImmediate(() => {
-            stream.emit('request');
             // eslint-disable-next-line @typescript-eslint/no-explicit-any
             (emitters!.shift() as any)(stream);
           });
@@ -2372,7 +2371,6 @@ describe('Bigtable/Table', () => {
             });
 
             setImmediate(() => {
-              stream.emit('request');
               stream.emit('error', error);
             });
 
@@ -2525,7 +2523,6 @@ describe('Bigtable/Table', () => {
           });
 
           setImmediate(() => {
-            stream.emit('request');
             stream.end({entries: fakeStatuses.shift()});
           });