1 |
|
2 | var pull = require('../')
|
3 | var test = require('tape')
|
4 |
|
5 | test('reduce becomes through', function (t) {
|
6 | pull(
|
7 | pull.values([1,2,3]),
|
8 | pull.reduce(function (a, b) {return a + b}, 0, function (err, val) {
|
9 | t.equal(val, 6)
|
10 | t.end()
|
11 | })
|
12 | )
|
13 | })
|
14 |
|
15 | test('reduce without initial value', function (t) {
|
16 | pull(
|
17 | pull.values([1,2,3]),
|
18 | pull.reduce(function (a, b) {return a + b}, function (err, val) {
|
19 | t.equal(val, 6)
|
20 | t.end()
|
21 | })
|
22 | )
|
23 | })
|
24 |
|
25 |
|
26 | test('reduce becomes drain', function (t) {
|
27 | pull(
|
28 | pull.values([1,2,3]),
|
29 | pull.reduce(
|
30 | function (a, b) {return a + b},
|
31 | 0,
|
32 | function (err, acc) {
|
33 | t.equal(acc, 6)
|
34 | t.end()
|
35 | }
|
36 | )
|
37 | )
|
38 | })
|
39 |
|
40 |
|