git ssb

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
41