ARCHIVE/xahau.js
1
0
Fork 0
mirror of https://github.com/Xahau/xahau.js.git synced 2025-12-05 08:48:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

resend request in case server was disconnected after request was sent

Browse Source
This commit is contained in:
Ivan Tivonenko
2015-09-09 02:22:02 +03:00
parent 50acc4c708
commit c57cef4a21
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/core/request.js
View File

@@ -207,7 +207,12 @@ Request.prototype.callback = function(callback, successEvent, errorEvent) {
let called = false; let called = false;
function onReconnect() {
self.remote.request(self);
}
function requestSuccess(message) { function requestSuccess(message) {
self.remote.removeListener('connected', onReconnect);
if (!called) { if (!called) {
called = true; called = true;
callback.call(self, null, message); callback.call(self, null, message);
@@ -215,6 +220,7 @@ Request.prototype.callback = function(callback, successEvent, errorEvent) {
} }
function requestError(error) { function requestError(error) {
self.remote.removeListener('connected', onReconnect);
if (!called) { if (!called) {
called = true; called = true;
@@ -228,6 +234,9 @@ Request.prototype.callback = function(callback, successEvent, errorEvent) {
this.once(this.successEvent, requestSuccess); this.once(this.successEvent, requestSuccess);
this.once(this.errorEvent, requestError); this.once(this.errorEvent, requestError);
if (this.remote.isConnected()) {
this.remote.once('connected', onReconnect);
}
this.request(); this.request();
return this; return this;