1 var test = require('tap').test
2 var concat = require('concat-stream')
4 var server = require('./lib/server.js')
5 var common = require('./lib/common.js')
6 var client = common.freshClient()
8 var testData = JSON.stringify({test: true})
9 var errorData = JSON.stringify({error: 'it went bad'})
11 test('streaming fetch', function (t) {
12 server.expect('/test', function (req, res) {
13 t.equal(req.method, 'GET', 'got expected method')
16 'content-type': 'application/json'
22 server.expect('/error', function (req, res) {
23 t.equal(req.method, 'GET', 'got expected method')
26 'content-type': 'application/json'
33 'http://localhost:1337/test',
36 t.ifError(er, 'loaded successfully')
38 var sink = concat(function (data) {
39 t.deepEqual(data.toString(), testData)
41 'http://localhost:1337/error',
44 t.ok(er, 'got an error')
51 res.on('error', function (error) {
52 t.ifError(error, 'no errors on stream')