@travetto/net
Advanced tools
Comparing version 0.4.4 to 0.4.5
@@ -22,4 +22,4 @@ { | ||
}, | ||
"version": "0.4.4", | ||
"gitHead": "cd17462f7331b7a5a74181cfa9a1573b7cd26f9e" | ||
"version": "0.4.5", | ||
"gitHead": "cae29fbc72727f9c9be6567c08e99c498675d227" | ||
} |
@@ -101,3 +101,3 @@ import * as http from 'http'; | ||
const req = client.request(requestOpts, (msg: http.IncomingMessage) => { | ||
const body = Buffer.from('', 'utf8'); | ||
const body: Buffer[] = []; | ||
@@ -108,5 +108,5 @@ if (!pipeTo) { | ||
msg.on('data', (chunk: string) => { | ||
msg.on('data', (chunk: Buffer) => { | ||
if ((msg.statusCode || 200) > 299 || !pipeTo) { | ||
body.write(chunk); | ||
body.push(Buffer.from(chunk)); | ||
} | ||
@@ -116,6 +116,7 @@ }); | ||
msg.on('end', () => { | ||
const bodyText = Buffer.concat(body).toString(); | ||
if ((msg.statusCode || 200) > 299) { | ||
reject({ message: body.toString(), status: msg.statusCode, headers: msg.headers }); | ||
reject({ message: bodyText, status: msg.statusCode, headers: msg.headers }); | ||
} else { | ||
resolve(pipeTo ? msg : body.toString()); | ||
resolve(pipeTo ? msg : bodyText); | ||
} | ||
@@ -122,0 +123,0 @@ }); |
7920
145