| 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 | })
|