fix: reduce through2 usage

Author: JustinBeckwith

package.json

@@ -33,7 +33,7 @@
     "docs-test": "linkinator docs",
     "fix": "gts fix",
     "prelint": "cd samples; npm link ../; npm install",
-    "lint": "gts fix",
+    "lint": "gts check",
     "prepare": "npm run compile",
     "samples-test": "cd samples/ && npm link ../ && npm install && npm test && cd ../",
     "snippet-test": "mocha samples/document-snippets/tests/*.js --timeout 600000",

src/table.ts

@@ -24,7 +24,6 @@ const concat = require('concat-stream');
 import * as is from 'is';
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const pumpify = require('pumpify');
-import * as through from 'through2';
 
 import {
   Family,
@@ -814,19 +813,22 @@ Please use the format 'prezzy' or '${instance.name}/tables/prezzy'.`);
       rowStream = pumpify.obj([
         requestStream,
         chunkTransformer,
-        through.obj((rowData, enc, next) => {
-          if (
-            chunkTransformer._destroyed ||
-            // eslint-disable-next-line @typescript-eslint/no-explicit-any
-            (userStream as any)._writableState.ended
-          ) {
-            return next();
-          }
-          numRequestsMade = 0;
-          rowsRead++;
-          const row = this.row(rowData.key);
-          row.data = rowData.data;
-          next(null, row);
+        new PassThrough({
+          objectMode: true,
+          transform: (rowData, enc, next) => {
+            if (
+              chunkTransformer._destroyed ||
+              // eslint-disable-next-line @typescript-eslint/no-explicit-any
+              (userStream as any)._writableState.ended
+            ) {
+              return next();
+            }
+            numRequestsMade = 0;
+            rowsRead++;
+            const row = this.row(rowData.key);
+            row.data = rowData.data;
+            next(null, row);
+          },
         }),
       ]);
 
@@ -1571,11 +1573,14 @@ Please use the format 'prezzy' or '${instance.name}/tables/prezzy'.`);
         reqOpts,
         gaxOpts: gaxOptions,
       }),
-      through.obj((key, enc, next) => {
-        next(null, {
-          key: key.rowKey,
-          offset: key.offsetBytes,
-        });
+      new PassThrough({
+        objectMode: true,
+        transform: (key, enc, next) => {
+          next(null, {
+            key: key.rowKey,
+            offset: key.offsetBytes,
+          });
+        },
       }),
     ]);
   }

system-test/mutate-rows.ts

@@ -29,7 +29,7 @@ import {PartialFailureError} from '@google-cloud/common/build/src/util';
 import {Entry} from '../src/table';
 import {CancellableStream, GrpcClient} from 'google-gax';
 import {BigtableClient} from '../src/v2';
-import { PassThrough } from 'stream';
+import {PassThrough} from 'stream';
 
 const {grpc} = new GrpcClient();