diff --git a/lib/sse.js b/lib/sse.js index b90f6a6..073e52e 100644 --- a/lib/sse.js +++ b/lib/sse.js @@ -195,6 +195,8 @@ var SSE = function (url, options) { // Parse the last chunk. this.dispatchEvent(this._parseEventChunk(this.chunk)); this.chunk = ''; + + this._markClosed(); }; /** @@ -273,8 +275,6 @@ var SSE = function (url, options) { event.headers = headers; this.dispatchEvent(event); this._setReadyState(this.OPEN); - } else if (this.xhr.readyState === XMLHttpRequest.DONE) { -- this._markClosed(); } };