| 1 |
|
| 2 | var tape = require('tape')
|
| 3 |
|
| 4 | var pull = require('../')
|
| 5 |
|
| 6 |
|
| 7 | tape('map throughs ends stream', function (t) {
|
| 8 | var err = new Error('unwholesome number')
|
| 9 | pull(
|
| 10 | pull.values([1,2,3,3.4,4]),
|
| 11 | pull.map(function (e) {
|
| 12 | if(e !== ~~e)
|
| 13 | throw err
|
| 14 | }),
|
| 15 | pull.drain(null, function (_err) {
|
| 16 | t.equal(_err, err)
|
| 17 | t.end()
|
| 18 | })
|
| 19 | )
|
| 20 | })
|