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