JS: Add tests with missing flow.

Author: MathiasVP

javascript/ql/test/library-tests/frameworks/NodeJSLib/stream-pipe.js

@@ -171,7 +171,12 @@ class HookTransform extends Transform {
   }
 }
 
-Readable.from([source("transform-hook")]).pipe(new HookTransform());
+Readable.from([source("transform-hook")]).pipe(new HookTransform()).pipe({
+  write(chunk) {
+    consumeChunk(chunk); // $ MISSING: flow=transform-hook
+    return true;
+  }
+});
 
 class OverriddenWriteDestination extends Writable {
   write(chunk) {
@@ -261,7 +266,12 @@ const transformOptions = {
 const transformOptionsAlias = transformOptions;
 const { Transform: ImportedTransform } = require("node:stream");
 const optionsTransform = new ImportedTransform(transformOptionsAlias);
-Readable.from([source("options-transform")]).pipe(optionsTransform);
+Readable.from([source("options-transform")]).pipe(optionsTransform).pipe({
+  write(chunk) {
+    consumeChunk(chunk); // $ MISSING: flow=options-transform
+    return true;
+  }
+});
 
 const optionsDuplex = new Duplex({
   read() {},
@@ -297,3 +307,38 @@ overriddenOptionsDestination.write = function(chunk) {
   return true;
 };
 Readable.from([source("options-public-write")]).pipe(overriddenOptionsDestination);
+
+class PushingTransform extends Transform {
+  _transform(chunk, encoding, callback) {
+    this.push(chunk);
+    callback();
+  }
+}
+Readable.from([source("transform-push")]).pipe(new PushingTransform()).pipe({
+  write(chunk) {
+    consumeChunk(chunk); // $ MISSING: flow=transform-push
+    return true;
+  }
+});
+
+Readable.from([source("dropped-transform-input")]).pipe(new Transform({
+  transform(chunk, encoding, callback) {
+    callback();
+  }
+})).pipe({
+  write(chunk) {
+    consumeChunk(chunk);
+    return true;
+  }
+});
+
+Readable.from([source("replaced-transform-input")]).pipe(new Transform({
+  transform(chunk, encoding, callback) {
+    callback(null, source("replacement-output"));
+  }
+})).pipe({
+  write(chunk) {
+    consumeChunk(chunk); // $ MISSING: flow=replacement-output
+    return true;
+  }
+});