-
Notifications
You must be signed in to change notification settings - Fork 0
/
test.js
106 lines (92 loc) · 2 KB
/
test.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
var test = require('tape')
var pull = require('pull-stream')
var drain = require('./')
var values = pull.values
var map = pull.map
var count = pull.count
var error = pull.error
test('drains', function (t) {
t.plan(2)
var result = []
pull(
values([1, 2, 3, 4, 5]),
map(x => x * 3),
drain(x => result.push(x))
)(function (err) {
t.false(err, 'no error')
t.same(result, [3, 6, 9, 12, 15], 'drains')
})
})
test('abort', function (t) {
t.plan(5)
var result = []
pull(
count(20),
drain(function (item) {
var i = result.push(item)
if (i > 3) return false
})
)(function (err) {
t.false(err, 'no error')
t.same(result, [0, 1, 2, 3], 'aborts with return false')
})
var drainer = drain(function (item) {
var i = result.push(item)
if (i > 9) drainer.abort()
})
pull(
count(20),
drainer
)(function (err) {
t.false(err, 'no error again')
t.same(result, [0, 1, 2, 3, 0, 1, 2, 3, 4, 5], 'aborts with .abort method')
})
var empty = []
var earlyAbort = drain(function (item) {
empty.push(item)
})
earlyAbort.abort()
pull(
count(20),
earlyAbort
)(function (err) {
t.false(empty.length, 'aborts early')
})
})
test('error', function (t) {
t.plan(2)
pull(
error(new Error('test error')),
drain(function (item) {
t.fail('does not drain')
})
)(function (err) {
t.is(err.message, 'test error', 'has normal error')
})
var drainer = drain(function (item) {
if (item > 5) drainer.abort(new Error('test error'))
})
pull(
count(10),
drainer
)(function (err) {
t.is(err.message, 'test error', 'has abort error')
})
})
test('no callback continuable', function (t) {
t.plan(2)
var result = []
pull(
count(5),
drain(result.push.bind(result))
)()
t.same(result, [0, 1, 2, 3, 4, 5], 'runs fine')
try {
pull(
error(new Error('test error')),
drain()
)()
} catch (err) {
t.same(err.message, 'test error', 'does not swallow errors')
}
})