git ssb

1
var tape = require('tape')
2
3
function curry (fun) {
4
  return function () {
5
    var args = [].slice.call(arguments)
6
    return function (read) {
7
      return fun.apply(null, [read].concat(args))
8
    }
9
  }
10
}
11
12
var pull = require('../')
13
14
function values (array) {
15
  var i = 0
16
  return function (abort, cb) {
17
    if(abort) i = array.length, cb(abort)
18
    else if(i >= array.length) cb(true)
19
    else cb(null, array[i++])
20
  }
21
}
22
23
var map = curry(function (read, mapper) {
24
    return function (abort, cb) {
25
      read(abort, function (end, data) {
26
        if(end) cb(end)
27
        else cb(null, mapper(data))
28
      })
29
    }
30
  })
31
32
var sum = curry(function (read, done) {
33
    var total = 0
34
    read(null, function next (end, data) {
35
        if(end) return done(end === true ? null : end, total)
36
        total += data
37
        read(null, next)
38
      })
39
  })
40
41
var log = curry(function (read) {
42
    return function (abort, cb) {
43
      read(abort, function (end, data) {
44
        if(end) return cb(end)
45
        console.error(data)
46
        cb(null, data)
47
      })
48
    }
49
  })
50
51
tape('wrap pull streams into stream', function (t) {
52
53
  pull(
54
    values([1, 2, 3, 4, 5, 6, 7, 8, 9, 10]),
55
    map(function (e) { return e*e }),
56
    log(),
57
    sum(function (err, value) {
58
      console.log(value)
59
      t.equal(value, 385)
60
      t.end()
61
    })
62
  )
63
64
})
65
66
tape('turn pull(through,...) -> Through', function (t) {
67
68
  pull(
69
    values([1, 2, 3, 4, 5, 6, 7, 8, 9, 10]),
70
    pull(
71
      map(function (e) { return e*e }),
72
      log()
73
    ),
74
    sum(function (err, value) {
75
      console.log(value)
76
      t.equal(value, 385)
77
      t.end()
78
    })
79
  )
80
81
})
82
83
//  pull(
84
//    values ([1 2 3 4 5 6 7 8 9 10])
85
//    pull(
86
//      map({x y;: e*e })
87
//      log()
88
//    )
89
//    sum({
90
//      err value:
91
//        t.equal(value 385)
92
//        t.end()
93
//      })
94
//  )
95
//
96
97
tape("writable pull() should throw when called twice", function (t) {
98
  t.plan(2)
99
100
  var stream = pull(
101
    map(function (e) { return e*e }),
102
    sum(function (err, value) {
103
      console.log(value)
104
      t.equal(value, 385)
105
    })
106
  )
107
108
  stream(values([1, 2, 3, 4, 5, 6, 7, 8, 9, 10]))
109
110
  t.throws(function () {
111
    stream(values([1, 2, 3, 4, 5, 6, 7, 8, 9, 10]))
112
  }, TypeError)
113
})
114