fix(deps): update dependency @google-cloud/common to v3 and handle st…

…ream ending (#704)

* fix: handle unpiping at userStream end
* fix: check for defined rowStream and use builtins

Co-authored-by: Benjamin E. Coe <bencoe@google.com>

package.json

@@ -43,7 +43,7 @@
     "test": "c8 mocha build/test"
   },
   "dependencies": {
-    "@google-cloud/common": "^2.2.2",
+    "@google-cloud/common": "^3.0.0",
     "@google-cloud/paginator": "^3.0.0",
     "@google-cloud/projectify": "^2.0.0",
     "@google-cloud/promisify": "^2.0.0",

src/table.ts

@@ -17,6 +17,7 @@ import {promisifyAll} from '@google-cloud/promisify';
 import arrify = require('arrify');
 import {ServiceError} from 'google-gax';
 import {decorateStatus} from './decorateStatus';
+import {PassThrough} from 'stream';
 
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const concat = require('concat-stream');
@@ -683,16 +684,18 @@ Please use the format 'prezzy' or '${instance.name}/tables/prezzy'.`);
       rowsLimit = options.limit;
     }
 
-    const userStream = through.obj();
+    const userStream = new PassThrough({objectMode: true});
     const end = userStream.end.bind(userStream);
     userStream.end = () => {
+      rowStream?.unpipe(userStream);
       if (activeRequestStream) {
         activeRequestStream.abort();
       }
       end();
     };
 
     let chunkTransformer: ChunkTransformer;
+    let rowStream: Duplex;
 
     const makeNewRequest = () => {
       const lastRowKey = chunkTransformer ? chunkTransformer.lastRowKey : '';
@@ -808,7 +811,7 @@ Please use the format 'prezzy' or '${instance.name}/tables/prezzy'.`);
 
       requestStream!.on('request', () => numRequestsMade++);
 
-      const rowStream: Duplex = pumpify.obj([
+      rowStream = pumpify.obj([
         requestStream,
         chunkTransformer,
         through.obj((rowData, enc, next) => {