@@ -5,10 +5,11 @@ import (
5
5
"testing"
6
6
7
7
"github.com/life4/genesis/channels"
8
- "github.com/stretchr/testify/require "
8
+ "github.com/matryer/is "
9
9
)
10
10
11
11
func TestToSlice (t * testing.T ) {
12
+ is := is .New (t )
12
13
f := func (given []int ) {
13
14
c := make (chan int , 1 )
14
15
go func () {
@@ -18,14 +19,15 @@ func TestToSlice(t *testing.T) {
18
19
close (c )
19
20
}()
20
21
actual := channels .ToSlice (c )
21
- require .Equal (t , given , actual )
22
+ is .Equal (given , actual )
22
23
}
23
24
f ([]int {})
24
25
f ([]int {1 })
25
26
f ([]int {1 , 2 , 3 , 1 , 2 })
26
27
}
27
28
28
29
func TestAny (t * testing.T ) {
30
+ is := is .New (t )
29
31
f := func (given []int , expected bool ) {
30
32
even := func (t int ) bool { return t % 2 == 0 }
31
33
c := make (chan int , 1 )
@@ -36,7 +38,7 @@ func TestAny(t *testing.T) {
36
38
close (c )
37
39
}()
38
40
actual := channels .Any (c , even )
39
- require .Equal (t , expected , actual )
41
+ is .Equal (expected , actual )
40
42
}
41
43
f ([]int {}, false )
42
44
f ([]int {1 }, false )
@@ -49,6 +51,7 @@ func TestAny(t *testing.T) {
49
51
}
50
52
51
53
func TestAll (t * testing.T ) {
54
+ is := is .New (t )
52
55
f := func (given []int , expected bool ) {
53
56
even := func (t int ) bool { return t % 2 == 0 }
54
57
c := make (chan int , 1 )
@@ -59,7 +62,7 @@ func TestAll(t *testing.T) {
59
62
close (c )
60
63
}()
61
64
actual := channels .All (c , even )
62
- require .Equal (t , expected , actual )
65
+ is .Equal (expected , actual )
63
66
}
64
67
f ([]int {}, true )
65
68
f ([]int {1 }, false )
@@ -71,6 +74,7 @@ func TestAll(t *testing.T) {
71
74
}
72
75
73
76
func TestEach (t * testing.T ) {
77
+ is := is .New (t )
74
78
f := func (given []int ) {
75
79
c := make (chan int , 1 )
76
80
go func () {
@@ -84,7 +88,7 @@ func TestEach(t *testing.T) {
84
88
channels .Each (c , mapper )
85
89
close (result )
86
90
actual := channels .ToSlice (result )
87
- require .Equal (t , given , actual )
91
+ is .Equal (given , actual )
88
92
}
89
93
90
94
f ([]int {})
@@ -94,6 +98,7 @@ func TestEach(t *testing.T) {
94
98
}
95
99
96
100
func TestChunkEvery (t * testing.T ) {
101
+ is := is .New (t )
97
102
f := func (size int , given []int , expected [][]int ) {
98
103
c := make (chan int , 1 )
99
104
go func () {
@@ -107,7 +112,7 @@ func TestChunkEvery(t *testing.T) {
107
112
for el := range result {
108
113
actual = append (actual , el )
109
114
}
110
- require .Equal (t , expected , actual )
115
+ is .Equal (expected , actual )
111
116
}
112
117
f (2 , []int {}, [][]int {})
113
118
f (2 , []int {1 }, [][]int {{1 }})
@@ -117,6 +122,7 @@ func TestChunkEvery(t *testing.T) {
117
122
}
118
123
119
124
func TestCount (t * testing.T ) {
125
+ is := is .New (t )
120
126
f := func (element int , given []int , expected int ) {
121
127
c := make (chan int , 1 )
122
128
go func () {
@@ -126,7 +132,7 @@ func TestCount(t *testing.T) {
126
132
close (c )
127
133
}()
128
134
actual := channels .Count (c , element )
129
- require .Equal (t , expected , actual )
135
+ is .Equal (expected , actual )
130
136
}
131
137
f (1 , []int {}, 0 )
132
138
f (1 , []int {1 }, 1 )
@@ -135,6 +141,7 @@ func TestCount(t *testing.T) {
135
141
}
136
142
137
143
func TestDrop (t * testing.T ) {
144
+ is := is .New (t )
138
145
f := func (count int , given []int , expected []int ) {
139
146
c := make (chan int , 1 )
140
147
go func () {
@@ -148,7 +155,7 @@ func TestDrop(t *testing.T) {
148
155
for el := range result {
149
156
actual = append (actual , el )
150
157
}
151
- require .Equal (t , expected , actual )
158
+ is .Equal (expected , actual )
152
159
}
153
160
f (1 , []int {}, []int {})
154
161
f (1 , []int {2 }, []int {})
@@ -160,6 +167,7 @@ func TestDrop(t *testing.T) {
160
167
}
161
168
162
169
func TestFilter (t * testing.T ) {
170
+ is := is .New (t )
163
171
f := func (given []int , expected []int ) {
164
172
even := func (t int ) bool { return t % 2 == 0 }
165
173
c := make (chan int , 1 )
@@ -171,7 +179,7 @@ func TestFilter(t *testing.T) {
171
179
}()
172
180
result := channels .Filter (c , even )
173
181
actual := channels .ToSlice (result )
174
- require .Equal (t , expected , actual )
182
+ is .Equal (expected , actual )
175
183
}
176
184
f ([]int {}, []int {})
177
185
f ([]int {1 }, []int {})
@@ -180,6 +188,7 @@ func TestFilter(t *testing.T) {
180
188
}
181
189
182
190
func TestMap (t * testing.T ) {
191
+ is := is .New (t )
183
192
f := func (given []int , expected []int ) {
184
193
double := func (el int ) int { return (el * 2 ) }
185
194
c := make (chan int , 1 )
@@ -201,14 +210,15 @@ func TestMap(t *testing.T) {
201
210
}()
202
211
203
212
actual := channels .ToSlice (c2 )
204
- require .Equal (t , expected , actual )
213
+ is .Equal (expected , actual )
205
214
}
206
215
f ([]int {}, []int {})
207
216
f ([]int {1 }, []int {2 })
208
217
f ([]int {1 , 2 , 3 }, []int {2 , 4 , 6 })
209
218
}
210
219
211
220
func TestMax (t * testing.T ) {
221
+ is := is .New (t )
212
222
f := func (given []int , expected int , expectedErr error ) {
213
223
c := make (chan int , 1 )
214
224
go func () {
@@ -218,8 +228,8 @@ func TestMax(t *testing.T) {
218
228
close (c )
219
229
}()
220
230
actual , actualErr := channels .Max (c )
221
- require .Equal (t , expected , actual )
222
- require .Equal (t , expectedErr , actualErr )
231
+ is .Equal (expected , actual )
232
+ is .Equal (expectedErr , actualErr )
223
233
}
224
234
f ([]int {}, 0 , channels .ErrEmpty )
225
235
f ([]int {1 , 4 , 2 }, 4 , nil )
@@ -228,6 +238,7 @@ func TestMax(t *testing.T) {
228
238
}
229
239
230
240
func TestMin (t * testing.T ) {
241
+ is := is .New (t )
231
242
f := func (given []int , expected int , expectedErr error ) {
232
243
c := make (chan int , 1 )
233
244
go func () {
@@ -237,8 +248,8 @@ func TestMin(t *testing.T) {
237
248
close (c )
238
249
}()
239
250
actual , actualErr := channels .Min (c )
240
- require .Equal (t , expected , actual )
241
- require .Equal (t , expectedErr , actualErr )
251
+ is .Equal (expected , actual )
252
+ is .Equal (expectedErr , actualErr )
242
253
}
243
254
f ([]int {}, 0 , channels .ErrEmpty )
244
255
f ([]int {4 , 1 , 2 }, 1 , nil )
@@ -247,6 +258,7 @@ func TestMin(t *testing.T) {
247
258
}
248
259
249
260
func TestReduce (t * testing.T ) {
261
+ is := is .New (t )
250
262
f := func (given []int , expected int ) {
251
263
c := make (chan int , 1 )
252
264
go func () {
@@ -257,7 +269,7 @@ func TestReduce(t *testing.T) {
257
269
}()
258
270
sum := func (el int , acc int ) int { return (el ) + acc }
259
271
actual := channels .Reduce (c , 0 , sum )
260
- require .Equal (t , expected , actual )
272
+ is .Equal (expected , actual )
261
273
}
262
274
f ([]int {}, 0 )
263
275
f ([]int {1 }, 1 )
@@ -266,6 +278,7 @@ func TestReduce(t *testing.T) {
266
278
}
267
279
268
280
func TestScan (t * testing.T ) {
281
+ is := is .New (t )
269
282
f := func (given []int , expected []int ) {
270
283
c := make (chan int , 1 )
271
284
go func () {
@@ -287,7 +300,7 @@ func TestScan(t *testing.T) {
287
300
}()
288
301
289
302
actual := channels .ToSlice (c2 )
290
- require .Equal (t , expected , actual )
303
+ is .Equal (expected , actual )
291
304
}
292
305
f ([]int {}, []int {})
293
306
f ([]int {1 }, []int {1 })
@@ -296,6 +309,7 @@ func TestScan(t *testing.T) {
296
309
}
297
310
298
311
func TestSum (t * testing.T ) {
312
+ is := is .New (t )
299
313
f := func (given []int , expected int ) {
300
314
c := make (chan int , 1 )
301
315
go func () {
@@ -305,7 +319,7 @@ func TestSum(t *testing.T) {
305
319
close (c )
306
320
}()
307
321
actual := channels .Sum (c )
308
- require .Equal (t , expected , actual )
322
+ is .Equal (expected , actual )
309
323
}
310
324
f ([]int {}, 0 )
311
325
f ([]int {1 }, 1 )
@@ -314,20 +328,22 @@ func TestSum(t *testing.T) {
314
328
}
315
329
316
330
func TestTake (t * testing.T ) {
331
+ is := is .New (t )
317
332
f := func (count int , given int , expected []int ) {
318
333
ctx , cancel := context .WithCancel (context .Background ())
319
334
seq := channels .Repeat (ctx , given )
320
335
seq2 := channels .Take (seq , count )
321
336
actual := channels .ToSlice (seq2 )
322
337
cancel ()
323
- require .Equal (t , expected , actual )
338
+ is .Equal (expected , actual )
324
339
}
325
340
f (0 , 1 , []int {})
326
341
f (1 , 1 , []int {1 })
327
342
f (2 , 1 , []int {1 , 1 })
328
343
}
329
344
330
345
func TestTee (t * testing.T ) {
346
+ is := is .New (t )
331
347
f := func (count int , given []int ) {
332
348
c := make (chan int , 1 )
333
349
go func () {
@@ -340,7 +356,7 @@ func TestTee(t *testing.T) {
340
356
for _ , ch := range chans {
341
357
go func (ch chan int ) {
342
358
actual := channels .ToSlice (ch )
343
- require .Equal (t , given , actual )
359
+ is .Equal (given , actual )
344
360
}(ch )
345
361
}
346
362
}
0 commit comments