@8base/file-server-sdk
Advanced tools
Comparing version 0.0.17 to 0.0.18
@@ -25,11 +25,18 @@ var __extends = (this && this.__extends) || (function () { | ||
return new Observable(function (observer) { | ||
var preventComplete = false; | ||
var subscriber = { | ||
next: function (data) { | ||
if (data.errors && data.errors[0].code === errorCodes.TokenExpiredErrorCode) { | ||
preventComplete = true; | ||
_this.refreshToken(_this.setRefreshTokenInput(), function (op) { return forward({ query: op }); }) | ||
.then(function (auth) { | ||
_this.authReceived(auth); | ||
preventComplete = false; | ||
var observable = forward(operation); | ||
if (_this.subscription) { | ||
_this.subscription.unsubscribe(); | ||
} | ||
_this.subscription = observable.subscribe(subscriber); | ||
}).catch(function (err) { | ||
preventComplete = false; | ||
observer.error(err); | ||
@@ -42,3 +49,7 @@ }); | ||
}, | ||
complete: observer.complete.bind(observer), | ||
complete: function () { | ||
if (!preventComplete) { | ||
observer.complete.bind(observer)(); | ||
} | ||
}, | ||
}; | ||
@@ -45,0 +56,0 @@ _this.subscription = forward(operation).subscribe(subscriber); |
{ | ||
"name": "@8base/file-server-sdk", | ||
"version": "0.0.17", | ||
"version": "0.0.18", | ||
"description": "JavaScript SDK for working with files at 8base", | ||
@@ -5,0 +5,0 @@ "main": "./lib/index.js", |
Sorry, the diff of this file is not supported yet
107154
2615