1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
var concat = require('../')
var test = require('tape')
test('writing objects', function (t) {
var stream = concat({encoding: "objects"}, concatted)
function concatted(objs) {
t.equal(objs.length, 2)
t.deepEqual(objs[0], {"foo": "bar"})
t.deepEqual(objs[1], {"baz": "taco"})
}
stream.write({"foo": "bar"})
stream.write({"baz": "taco"})
stream.end()
t.end()
})
test('switch to objects encoding if no encoding specified and objects are written', function (t) {
var stream = concat(concatted)
function concatted(objs) {
t.equal(objs.length, 2)
t.deepEqual(objs[0], {"foo": "bar"})
t.deepEqual(objs[1], {"baz": "taco"})
}
stream.write({"foo": "bar"})
stream.write({"baz": "taco"})
stream.end()
t.end()
})
|