1 2var test = require('tape') 3 4var JSONStream = require('../') 5 6test('map function', function (t) { 7 8 var actual = [] 9 10 stream = JSONStream.parse([true], function (e) { return e*10 }) 11 stream.on('data', function (v) { actual.push(v)}) 12 stream.on('end', function () { 13 t.deepEqual(actual, [10,20,30,40,50,60]) 14 t.end() 15 16 }) 17 18 stream.write(JSON.stringify([1,2,3,4,5,6], null, 2)) 19 stream.end() 20 21}) 22 23test('filter function', function (t) { 24 25 var actual = [] 26 27 stream = JSONStream 28 .parse([true], function (e) { return e%2 ? e : null}) 29 .on('data', function (v) { actual.push(v)}) 30 .on('end', function () { 31 t.deepEqual(actual, [1,3,5]) 32 t.end() 33 34 }) 35 36 stream.write(JSON.stringify([1,2,3,4,5,6], null, 2)) 37 stream.end() 38 39}) 40 41