Skip to content

Commit

Permalink
Changes to queueTransformStream
Browse files Browse the repository at this point in the history
  • Loading branch information
mshima committed Feb 15, 2021
1 parent 632d60d commit 6d6c4b0
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions lib/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -1335,15 +1335,15 @@ class Generator extends Base {
* or a single one.
* @return {this} This generator
*/
queueTransformStream(streams) {
assert(streams, 'expected to receive a transform stream as parameter');
if (!Array.isArray(streams)) {
streams = [streams];
}
queueTransformStream(transformStreams) {
assert(
transformStreams,
'expected to receive a transform stream as parameter'
);

this.queueTask({
method() {
return this.env.applyTransforms(streams);
return this.env.applyTransforms(transformStreams);
},
taskName: 'transformStream',
queueName: 'transform'
Expand Down

0 comments on commit 6d6c4b0

Please sign in to comment.