Skip to content
This repository was archived by the owner on Jan 19, 2021. It is now read-only.

Commit ecee084

Browse files
committed
fix(parallel-transform): return a class instead of an instance in .create
1 parent f692d14 commit ecee084

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/parallel-transform.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ export default class ParallelTransform extends stream.Transform {
5353
_parallelTransform = transformFunction;
5454
}
5555

56-
return new Transform();
56+
return Transform;
5757
}
5858

5959
/**

test/parallel-transform.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -72,9 +72,9 @@ test.cb('should pass options on to the stream.Transform constructor', t => {
7272
});
7373

7474
test('should allow instantiation via function call', t => {
75-
const stream = ParallelTransform.create(1, (data, encoding, done) => {
75+
const PStream = ParallelTransform.create(1, (data, encoding, done) => {
7676
done(null, data);
7777
});
7878

79-
t.true(stream instanceof ParallelTransform);
79+
t.true(new PStream() instanceof ParallelTransform);
8080
});

0 commit comments

Comments
 (0)