Rename registerTransformStream to queueTransformStream

yeoman · Feb 13, 2021 · b25267a · b25267a
1 parent 805ecb9
commit b25267a
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 6 deletions.
diff --git a/lib/index.js b/lib/index.js
@@ -149,7 +149,6 @@ class Generator extends EventEmitter {
     this._arguments = [];
     this._prompts = [];
     this._composedWith = [];
-    this._transformStreams = [];
     this._namespace = this.options.namespace;
     this._namespaceId = this.options.namespaceId;
     this.yoGeneratorVersion = packageJson.version;
@@ -1300,13 +1299,19 @@ class Generator extends EventEmitter {
    * or a single one.
    * @return {this} This generator
    */
-  registerTransformStream(streams) {
+  queueTransformStream(streams) {
     assert(streams, 'expected to receive a transform stream as parameter');
     if (!Array.isArray(streams)) {
       streams = [streams];
     }
 
-    this._transformStreams = this._transformStreams.concat(streams);
+    this.queueTask({
+      method() {
+        return this.env.applyTransforms(streams);
+      },
+      taskName: 'transformStream',
+      queueName: 'transform'
+    });
     return this;
   }
 }

diff --git a/test/base.js b/test/base.js
@@ -1160,12 +1160,12 @@ describe('Base', () => {
       this.TestGenerator.prototype.writing = function () {
         this.fs.write(self.filepath, 'not correct');
 
-        this.registerTransformStream(
+        this.queueTransformStream(
           through.obj((file, enc, cb) => {
             file.contents = Buffer.from('a');
             cb(null, file);
           })
-        ).registerTransformStream(
+        ).queueTransformStream(
           through.obj((file, enc, cb) => {
             file.contents = Buffer.from(file.contents.toString() + 'b');
             cb(null, file);
@@ -1183,7 +1183,7 @@ describe('Base', () => {
       this.TestGenerator.prototype.writing = function () {
         this.fs.write(self.filepath, 'not correct');
 
-        this.registerTransformStream([
+        this.queueTransformStream([
           through.obj((file, enc, cb) => {
             file.contents = Buffer.from('a');
             cb(null, file);