Skip to content

Commit

Permalink
add options to queueTransformStream.
Browse files Browse the repository at this point in the history
  • Loading branch information
mshima committed Feb 11, 2023
1 parent 58bd701 commit dac0db6
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions lib/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -1543,17 +1543,18 @@ this.composeWith({
*
* @param {stream.Transform|stream.Transform[]} streams An array of Transform stream
* or a single one.
* @param {any} options Environment.applyTransforms options parameter
* @return {this} This generator
*/
queueTransformStream(transformStreams) {
queueTransformStream(transformStreams, options) {
assert(
transformStreams,
'expected to receive a transform stream as parameter'
);

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

0 comments on commit dac0db6

Please sign in to comment.