| 1 | # pull-stream/throughs/flatten
|
| 2 |
|
| 3 | ## usage
|
| 4 | ### `flatten = require('pull-stream/throughs/flatten')`
|
| 5 | ### `flatten(streams)`
|
| 6 | Turn a stream of streams or a stream of arrays into a stream of their items, (undoes group).
|
| 7 |
|
| 8 |
|
| 9 | ## example
|
| 10 | ```js
|
| 11 | test('flatten arrays', function (t) {
|
| 12 | pull(
|
| 13 | pull.values([
|
| 14 | [1, 2, 3],
|
| 15 | [4, 5, 6],
|
| 16 | [7, 8, 9]
|
| 17 | ]),
|
| 18 | pull.flatten(),
|
| 19 | pull.collect(function (err, numbers) {
|
| 20 | t.deepEqual([1, 2, 3, 4, 5, 6, 7, 8, 9], numbers)
|
| 21 | t.end()
|
| 22 | })
|
| 23 | )
|
| 24 | })
|
| 25 |
|
| 26 | test('flatten stream of streams', function (t) {
|
| 27 |
|
| 28 | pull(
|
| 29 | pull.values([
|
| 30 | pull.values([1, 2, 3]),
|
| 31 | pull.values([4, 5, 6]),
|
| 32 | pull.values([7, 8, 9])
|
| 33 | ]),
|
| 34 | pull.flatten(),
|
| 35 | pull.collect(function (err, numbers) {
|
| 36 | t.deepEqual([1, 2, 3, 4, 5, 6, 7, 8, 9], numbers)
|
| 37 | t.end()
|
| 38 | })
|
| 39 | )
|
| 40 |
|
| 41 | })
|
| 42 | ```
|