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