-
-
Notifications
You must be signed in to change notification settings - Fork 6
/
Copy pathtest.js
125 lines (93 loc) · 3.13 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
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
const { Readable } = require('streamx')
const tape = require('tape')
const Union = require('./')
tape('numbers', function (t) {
const a = Readable.from([4, 6, 10, 14, 15, 20, 22])
const b = Readable.from([6, 11, 20])
const u = new Union(a, b)
const expected = [4, 6, 10, 11, 14, 15, 20, 22]
u.on('data', function (data) {
t.same(data, expected.shift())
})
u.on('end', function () {
t.same(expected.length, 0, 'no more data')
t.end()
})
})
tape('string', function (t) {
const a = Readable.from(['04', '06', '10', '14', '15', '20', '22'])
const b = Readable.from(['06', '11', '20'])
const u = new Union(a, b)
const expected = ['04', '06', '10', '11', '14', '15', '20', '22']
u.on('data', function (data) {
t.same(data, expected.shift())
})
u.on('end', function () {
t.same(expected.length, 0, 'no more data')
t.end()
})
})
tape('objects', function (t) {
const a = Readable.from([{ key: '04' }, { key: '06' }, { key: '10' }, { key: '14' }, { key: '15' }, { key: '20' }, { key: '22' }])
const b = Readable.from([{ key: '06' }, { key: '11' }, { key: '20' }])
const u = new Union(a, b, (a, b) => a.key < b.key ? -1 : a.key > b.key ? 1 : 0)
const expected = [{ key: '04' }, { key: '06' }, { key: '10' }, { key: '11' }, { key: '14' }, { key: '15' }, { key: '20' }, { key: '22' }]
u.on('data', function (data) {
t.same(data, expected.shift())
})
u.on('end', function () {
t.same(expected.length, 0, 'no more data')
t.end()
})
})
tape('custom objects', function (t) {
const a = Readable.from([{ bar: '04' }, { bar: '06' }, { bar: '10' }, { bar: '14' }, { bar: '15' }, { bar: '20' }, { bar: '22' }])
const b = Readable.from([{ bar: '06' }, { bar: '11' }, { bar: '20' }])
const u = new Union(a, b, (a, b) => a.bar < b.bar ? -1 : a.bar > b.bar ? 1 : 0)
const expected = [{ bar: '04' }, { bar: '06' }, { bar: '10' }, { bar: '11' }, { bar: '14' }, { bar: '15' }, { bar: '20' }, { bar: '22' }]
u.on('data', function (data) {
t.same(data, expected.shift())
})
u.on('end', function () {
t.same(expected.length, 0, 'no more data')
t.end()
})
})
tape('destroy stream', function (t) {
var a = new Readable()
var b = new Readable()
t.plan(2)
a.on('close', function () {
t.ok(true)
})
b.on('close', function () {
t.ok(true)
})
new Union(a, b).destroy()
})
tape('both option', function (t) {
const a = Readable.from([4, 6, 10, 14, 15, 20, 22])
const b = Readable.from([6, 11, 20])
const u = new Union(a, b, { both: true })
const expected = [4, 6, 6, 10, 11, 14, 15, 20, 20, 22]
u.on('data', function (data) {
t.same(data, expected.shift())
})
u.on('end', function () {
t.same(expected.length, 0, 'no more data')
t.end()
})
})
tape('map option with filter', function (t) {
const a = Readable.from([4, 6, 10, 20, 22])
const b = Readable.from([6, 11, 20])
const u = new Union(a, b, { map: (e1, e2) => e1 === e2 ? null : e1 || e2 })
const expected = [4, 10, 11, 22]
u.on('data', function (data) {
t.same(data, expected.shift())
})
u.on('end', function () {
t.same(expected.length, 0, 'no more data')
t.end()
})
})