@@ -16,28 +16,6 @@ const {
16
16
} ,
17
17
} = require ( 'internal/errors' ) ;
18
18
19
- // This is needed for pre node 17.
20
- class ComposeDuplex extends Duplex {
21
- constructor ( options ) {
22
- super ( options ) ;
23
-
24
- // https://github.com/nodejs/node/pull/34385
25
-
26
- if ( options ?. readable === false ) {
27
- this . _readableState . readable = false ;
28
- this . _readableState . ended = true ;
29
- this . _readableState . endEmitted = true ;
30
- }
31
-
32
- if ( options ?. writable === false ) {
33
- this . _writableState . writable = false ;
34
- this . _writableState . ending = true ;
35
- this . _writableState . ended = true ;
36
- this . _writableState . finished = true ;
37
- }
38
- }
39
- }
40
-
41
19
module . exports = function compose ( ...streams ) {
42
20
if ( streams . length === 0 ) {
43
21
throw new ERR_MISSING_ARGS ( 'streams' ) ;
@@ -107,7 +85,7 @@ module.exports = function compose(...streams) {
107
85
// TODO(ronag): Avoid double buffering.
108
86
// Implement Writable/Readable/Duplex traits.
109
87
// See, https://github.com/nodejs/node/pull/33515.
110
- d = new ComposeDuplex ( {
88
+ d = new Duplex ( {
111
89
// TODO (ronag): highWaterMark?
112
90
writableObjectMode : ! ! head ?. writableObjectMode ,
113
91
readableObjectMode : ! ! tail ?. writableObjectMode ,
0 commit comments