Files: d2f2697f296dd39aed6a8b63c6d04a736a7db5b3 / node_modules / pull-stream / docs / throughs / flatten.md
827 bytesRaw
pull-stream/throughs/flatten
usage
flatten = require('pull-stream/throughs/flatten')
flatten(streams)
Turn a stream of streams or a stream of arrays into a stream of their items, (undoes group).
example
test('flatten arrays', function (t) {
pull(
pull.values([
[1, 2, 3],
[4, 5, 6],
[7, 8, 9]
]),
pull.flatten(),
pull.collect(function (err, numbers) {
t.deepEqual([1, 2, 3, 4, 5, 6, 7, 8, 9], numbers)
t.end()
})
)
})
test('flatten stream of streams', function (t) {
pull(
pull.values([
pull.values([1, 2, 3]),
pull.values([4, 5, 6]),
pull.values([7, 8, 9])
]),
pull.flatten(),
pull.collect(function (err, numbers) {
t.deepEqual([1, 2, 3, 4, 5, 6, 7, 8, 9], numbers)
t.end()
})
)
})
Built with git-ssb-web