@@ -22,7 +22,11 @@ const isStream = (s) => !!s &&
2222 ( s instanceof Minipass ||
2323 s instanceof node_stream_1 . default ||
2424 ( 0 , exports . isReadable ) ( s ) ||
25- ( 0 , exports . isWritable ) ( s ) ) ;
25+ ( 0 , exports . isWritable ) ( s ) )
26+ /**
27+ * Return true if the argument is a valid {@link Minipass.Readable}
28+ */
29+ ;
2630exports . isStream = isStream ;
2731/**
2832 * Return true if the argument is a valid {@link Minipass.Readable}
@@ -32,7 +36,11 @@ const isReadable = (s) => !!s &&
3236 s instanceof node_events_1 . EventEmitter &&
3337 typeof s . pipe === 'function' &&
3438 // node core Writable streams have a pipe() method, but it throws
35- s . pipe !== node_stream_1 . default . Writable . prototype . pipe ;
39+ s . pipe !== node_stream_1 . default . Writable . prototype . pipe
40+ /**
41+ * Return true if the argument is a valid {@link Minipass.Writable}
42+ */
43+ ;
3644exports . isReadable = isReadable ;
3745/**
3846 * Return true if the argument is a valid {@link Minipass.Writable}
@@ -129,7 +137,7 @@ class PipeProxyErrors extends Pipe {
129137 }
130138 constructor ( src , dest , opts ) {
131139 super ( src , dest , opts ) ;
132- this . proxyErrors = er => dest . emit ( 'error' , er ) ;
140+ this . proxyErrors = ( er ) => this . dest . emit ( 'error' , er ) ;
133141 src . on ( 'error' , this . proxyErrors ) ;
134142 }
135143}
@@ -939,6 +947,7 @@ class Minipass extends node_events_1.EventEmitter {
939947 [ Symbol . asyncIterator ] ( ) {
940948 return this ;
941949 } ,
950+ [ Symbol . asyncDispose ] : async ( ) => { } ,
942951 } ;
943952 }
944953 /**
@@ -976,6 +985,7 @@ class Minipass extends node_events_1.EventEmitter {
976985 [ Symbol . iterator ] ( ) {
977986 return this ;
978987 } ,
988+ [ Symbol . dispose ] : ( ) => { } ,
979989 } ;
980990 }
981991 /**
0 commit comments