Compare commits
5 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 0f81836459 | |||
| 73f1e6f3f0 | |||
| d700e6d8d9 | |||
| 7cb4e22c9f | |||
| 9cb2a8db15 |
@@ -11,7 +11,7 @@ browsers:
|
||||
- name: opera
|
||||
version: 11..latest
|
||||
- name: iphone
|
||||
version: 5.0..latest
|
||||
version: 5.1..latest
|
||||
- name: android
|
||||
version: 4.0..latest
|
||||
server: ./test/server/index.js
|
||||
|
||||
+1
-1
@@ -109,7 +109,7 @@ ClientRequest.prototype._onFinish = function () {
|
||||
headers: headers,
|
||||
body: body,
|
||||
mode: 'cors',
|
||||
credentials: opts.credentials ? 'include' : 'omit'
|
||||
credentials: opts.withCredentials ? 'include' : 'omit'
|
||||
}).then(function (response) {
|
||||
self._fetchResponse = response
|
||||
self._connect()
|
||||
|
||||
@@ -39,7 +39,6 @@ var IncomingMessage = exports.IncomingMessage = function (xhr, response, mode) {
|
||||
reader.read().then(function (result) {
|
||||
if (result.done) {
|
||||
self.push(null)
|
||||
self.emit('close')
|
||||
return
|
||||
}
|
||||
self.push(new Buffer(result.value))
|
||||
@@ -151,7 +150,6 @@ IncomingMessage.prototype._onXHRProgress = function () {
|
||||
}
|
||||
reader.onload = function () {
|
||||
self.push(null)
|
||||
self.emit('close')
|
||||
}
|
||||
// reader.onerror = ??? // TODO: this
|
||||
reader.readAsArrayBuffer(response)
|
||||
@@ -161,6 +159,5 @@ IncomingMessage.prototype._onXHRProgress = function () {
|
||||
// The ms-stream case handles end separately in reader.onload()
|
||||
if (self._xhr.readyState === rStates.DONE && self._mode !== 'ms-stream') {
|
||||
self.push(null)
|
||||
self.emit('close')
|
||||
}
|
||||
}
|
||||
|
||||
+1
-1
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "stream-http",
|
||||
"version": "1.0.1",
|
||||
"version": "1.1.0",
|
||||
"description": "Streaming http in the browser",
|
||||
"main": "index.js",
|
||||
"repository": {
|
||||
|
||||
Reference in New Issue
Block a user