git ssb

1
2
3
var pull = require('../')
4
require('tape')('through - onEnd', function (t) {
5
  t.plan(2)
6
  pull(
7
    pull.infinite(),
8
    pull.through(null, function (err) {
9
      console.log('end')
10
      t.ok(true)
11
      process.nextTick(function () {
12
        t.end()
13
      })
14
    }),
15
    pull.take(10),
16
    pull.collect(function (err, ary) {
17
      console.log(ary)
18
      t.ok(true)
19
    })
20
  )
21
})
22