mirror of
https://github.com/tiennm99/FBcount.git
synced 2026-05-14 22:57:47 +00:00
MiTiX
27 lines
569 B
JavaScript
27 lines
569 B
JavaScript
var MultiStream = require('../')
|
|
var ary = require('array-to-stream')
|
|
var test = require('tape')
|
|
|
|
test('combine object streams', function (t) {
|
|
var objects = [true, {x: 'b'}, 'c', 'd', 'e', 'f']
|
|
|
|
var streams = [
|
|
ary(objects.slice(0, 2)),
|
|
ary(objects.slice(2, 3)),
|
|
ary(objects.slice(3))
|
|
]
|
|
|
|
var received = []
|
|
MultiStream.obj(streams)
|
|
.on('error', function (err) {
|
|
t.fail(err)
|
|
})
|
|
.on('data', function (object) {
|
|
received.push(object)
|
|
})
|
|
.on('end', function () {
|
|
t.same(objects, received)
|
|
t.end()
|
|
})
|
|
})
|