File tree 3 files changed +16
-0
lines changed
3 files changed +16
-0
lines changed Original file line number Diff line number Diff line change @@ -15,3 +15,7 @@ isStream.readable = function (stream) {
15
15
isStream . duplex = function ( stream ) {
16
16
return isStream . writable ( stream ) && isStream . readable ( stream ) ;
17
17
} ;
18
+
19
+ isStream . transform = function ( stream ) {
20
+ return isStream . duplex ( stream ) && typeof stream . _transform === 'function' && typeof stream . _transformState === 'object' ;
21
+ } ;
Original file line number Diff line number Diff line change @@ -34,6 +34,7 @@ isStream({});
34
34
35
35
#### isStream.duplex(stream)
36
36
37
+ #### isStream.transform(stream)
37
38
38
39
39
40
## License
Original file line number Diff line number Diff line change @@ -55,3 +55,14 @@ test('isStream.duplex()', t => {
55
55
t . false ( m . duplex ( fs . createReadStream ( 'test.js' ) ) ) ;
56
56
t . false ( m . duplex ( fs . createWriteStream ( tempfile ( ) ) ) ) ;
57
57
} ) ;
58
+
59
+ test ( 'isStream.transform()' , t => {
60
+ t . true ( m . transform ( new Stream . Transform ( ) ) ) ;
61
+ t . true ( m . transform ( new Stream . PassThrough ( ) ) ) ;
62
+ t . false ( m . transform ( new Stream . Duplex ( ) ) ) ;
63
+ t . false ( m . transform ( new Stream . Stream ( ) ) ) ;
64
+ t . false ( m . transform ( new Stream . Readable ( ) ) ) ;
65
+ t . false ( m . transform ( new Stream . Writable ( ) ) ) ;
66
+ t . false ( m . transform ( fs . createReadStream ( 'test.js' ) ) ) ;
67
+ t . false ( m . transform ( fs . createWriteStream ( tempfile ( ) ) ) ) ;
68
+ } ) ;
You can’t perform that action at this time.
0 commit comments