@@ -4,59 +4,59 @@ var Stream = require('stream');
4
4
var net = require ( 'net' ) ;
5
5
var test = require ( 'ava' ) ;
6
6
var tempfile = require ( 'tempfile' ) ;
7
- var isStream = require ( './' ) ;
7
+ var fn = require ( './' ) ;
8
8
9
9
test ( 'isStream()' , function ( t ) {
10
- t . assert ( isStream ( new Stream . Stream ( ) ) ) ;
11
- t . assert ( isStream ( new Stream . Readable ( ) ) ) ;
12
- t . assert ( isStream ( new Stream . Writable ( ) ) ) ;
13
- t . assert ( isStream ( new Stream . Duplex ( ) ) ) ;
14
- t . assert ( isStream ( new Stream . Transform ( ) ) ) ;
15
- t . assert ( isStream ( new Stream . PassThrough ( ) ) ) ;
16
- t . assert ( isStream ( fs . createReadStream ( 'test.js' ) ) ) ;
17
- t . assert ( isStream ( fs . createWriteStream ( tempfile ( ) ) ) ) ;
18
- t . assert ( ! isStream ( { } ) ) ;
19
- t . assert ( ! isStream ( null ) ) ;
20
- t . assert ( ! isStream ( undefined ) ) ;
21
- t . assert ( ! isStream ( '' ) ) ;
22
- t . assert ( isStream ( new net . Socket ( ) ) ) ;
10
+ t . true ( fn ( new Stream . Stream ( ) ) ) ;
11
+ t . true ( fn ( new Stream . Readable ( ) ) ) ;
12
+ t . true ( fn ( new Stream . Writable ( ) ) ) ;
13
+ t . true ( fn ( new Stream . Duplex ( ) ) ) ;
14
+ t . true ( fn ( new Stream . Transform ( ) ) ) ;
15
+ t . true ( fn ( new Stream . PassThrough ( ) ) ) ;
16
+ t . true ( fn ( fs . createReadStream ( 'test.js' ) ) ) ;
17
+ t . true ( fn ( fs . createWriteStream ( tempfile ( ) ) ) ) ;
18
+ t . true ( fn ( new net . Socket ( ) ) ) ;
19
+ t . false ( fn ( { } ) ) ;
20
+ t . false ( fn ( null ) ) ;
21
+ t . false ( fn ( undefined ) ) ;
22
+ t . false ( fn ( '' ) ) ;
23
23
t . end ( ) ;
24
24
} ) ;
25
25
26
26
test ( 'isStream.writable()' , function ( t ) {
27
- t . assert ( ! isStream . writable ( new Stream . Stream ( ) ) ) ;
28
- t . assert ( ! isStream . writable ( new Stream . Readable ( ) ) ) ;
29
- t . assert ( isStream . writable ( new Stream . Writable ( ) ) ) ;
30
- t . assert ( isStream . writable ( new Stream . Duplex ( ) ) ) ;
31
- t . assert ( isStream . writable ( new Stream . Transform ( ) ) ) ;
32
- t . assert ( isStream . writable ( new Stream . PassThrough ( ) ) ) ;
33
- t . assert ( ! isStream . writable ( fs . createReadStream ( 'test.js' ) ) ) ;
34
- t . assert ( isStream . writable ( fs . createWriteStream ( tempfile ( ) ) ) ) ;
35
- t . assert ( ! isStream . writable ( new net . Socket ( ) ) ) ;
27
+ t . true ( fn . writable ( new Stream . Writable ( ) ) ) ;
28
+ t . true ( fn . writable ( new Stream . Duplex ( ) ) ) ;
29
+ t . true ( fn . writable ( new Stream . Transform ( ) ) ) ;
30
+ t . true ( fn . writable ( new Stream . PassThrough ( ) ) ) ;
31
+ t . true ( fn . writable ( fs . createWriteStream ( tempfile ( ) ) ) ) ;
32
+ t . false ( fn . writable ( new Stream . Stream ( ) ) ) ;
33
+ t . false ( fn . writable ( new Stream . Readable ( ) ) ) ;
34
+ t . false ( fn . writable ( fs . createReadStream ( 'test.js' ) ) ) ;
35
+ t . false ( fn . writable ( new net . Socket ( ) ) ) ;
36
36
t . end ( ) ;
37
37
} ) ;
38
38
39
39
test ( 'isStream.readable()' , function ( t ) {
40
- t . assert ( ! isStream . readable ( new Stream . Stream ( ) ) ) ;
41
- t . assert ( isStream . readable ( new Stream . Readable ( ) ) ) ;
42
- t . assert ( ! isStream . readable ( new Stream . Writable ( ) ) ) ;
43
- t . assert ( isStream . readable ( new Stream . Duplex ( ) ) ) ;
44
- t . assert ( isStream . readable ( new Stream . Transform ( ) ) ) ;
45
- t . assert ( isStream . readable ( new Stream . PassThrough ( ) ) ) ;
46
- t . assert ( isStream . readable ( fs . createReadStream ( 'test.js' ) ) ) ;
47
- t . assert ( ! isStream . readable ( fs . createWriteStream ( tempfile ( ) ) ) ) ;
48
- t . assert ( ! isStream . readable ( new net . Socket ( ) ) ) ;
40
+ t . true ( fn . readable ( new Stream . Readable ( ) ) ) ;
41
+ t . true ( fn . readable ( new Stream . Duplex ( ) ) ) ;
42
+ t . true ( fn . readable ( new Stream . Transform ( ) ) ) ;
43
+ t . true ( fn . readable ( new Stream . PassThrough ( ) ) ) ;
44
+ t . true ( fn . readable ( fs . createReadStream ( 'test.js' ) ) ) ;
45
+ t . false ( fn . readable ( new Stream . Stream ( ) ) ) ;
46
+ t . false ( fn . readable ( new Stream . Writable ( ) ) ) ;
47
+ t . false ( fn . readable ( fs . createWriteStream ( tempfile ( ) ) ) ) ;
48
+ t . false ( fn . readable ( new net . Socket ( ) ) ) ;
49
49
t . end ( ) ;
50
50
} ) ;
51
51
52
52
test ( 'isStream.duplex()' , function ( t ) {
53
- t . assert ( ! isStream . duplex ( new Stream . Stream ( ) ) ) ;
54
- t . assert ( ! isStream . duplex ( new Stream . Readable ( ) ) ) ;
55
- t . assert ( ! isStream . duplex ( new Stream . Writable ( ) ) ) ;
56
- t . assert ( isStream . duplex ( new Stream . Duplex ( ) ) ) ;
57
- t . assert ( isStream . duplex ( new Stream . Transform ( ) ) ) ;
58
- t . assert ( isStream . duplex ( new Stream . PassThrough ( ) ) ) ;
59
- t . assert ( ! isStream . duplex ( fs . createReadStream ( 'test.js' ) ) ) ;
60
- t . assert ( ! isStream . duplex ( fs . createWriteStream ( tempfile ( ) ) ) ) ;
53
+ t . true ( fn . duplex ( new Stream . Duplex ( ) ) ) ;
54
+ t . true ( fn . duplex ( new Stream . Transform ( ) ) ) ;
55
+ t . true ( fn . duplex ( new Stream . PassThrough ( ) ) ) ;
56
+ t . false ( fn . duplex ( new Stream . Stream ( ) ) ) ;
57
+ t . false ( fn . duplex ( new Stream . Readable ( ) ) ) ;
58
+ t . false ( fn . duplex ( new Stream . Writable ( ) ) ) ;
59
+ t . false ( fn . duplex ( fs . createReadStream ( 'test.js' ) ) ) ;
60
+ t . false ( fn . duplex ( fs . createWriteStream ( tempfile ( ) ) ) ) ;
61
61
t . end ( ) ;
62
62
} ) ;
0 commit comments