Commit afd50019f28e08e55d71a9e1062ece706f728b63
Add failing test for flattening stream of broken streams
Jan Bölsche committed on 9/9/2015, 7:13:27 PMParent: 9cefb1fbc7f7c49a114bd09131273c22eac191b3
Files changed
| test/flatten.js | changed |
| test/flatten.js | ||
|---|---|---|
| @@ -52,5 +52,21 @@ | ||
| 52 | 52 | ) |
| 53 | 53 | |
| 54 | 54 | }) |
| 55 | 55 | |
| 56 | +test.only('flatten stream of broken streams', function (t) { | |
| 57 | + var _err = new Error('I am broken'); | |
| 58 | + pull( | |
| 59 | + pull.values([ | |
| 60 | + pull.Source(function read(abort, cb) { | |
| 61 | + cb(_err) | |
| 62 | + }) | |
| 63 | + ]), | |
| 64 | + pull.flatten(), | |
| 65 | + pull.onEnd(function (err) { | |
| 66 | + t.equal(err, _err) | |
| 67 | + t.end() | |
| 68 | + }) | |
| 69 | + ) | |
| 56 | 70 | |
| 71 | +}) | |
| 72 | + | |
Built with git-ssb-web