Comparing version 5.3.4 to 5.3.5
@@ -32,5 +32,8 @@ 'use strict'; | ||
}).then(function (resp) { | ||
return messageCallback(JSON.stringify(resp)); | ||
handledRequest = true; | ||
messageCallback(JSON.stringify(resp)); | ||
}).catch(function (err) { | ||
return messageCallback(JSON.stringify(unknownError(err, parsedRequest))); | ||
if (!handledRequest) { | ||
messageCallback(JSON.stringify(unknownError(err, parsedRequest))); | ||
} | ||
}); | ||
@@ -37,0 +40,0 @@ }, |
{ | ||
"name": "rxws", | ||
"version": "5.3.4", | ||
"version": "5.3.5", | ||
"description": "A RESTful reactive JavaScript implmentation on top of web sockets", | ||
@@ -5,0 +5,0 @@ "main": "lib/rxws.js", |
@@ -18,3 +18,3 @@ import { Observable } from 'rx'; | ||
.then(resp => parseResponse(parsedRequest, resp)) | ||
.then(resp => messageCallback(JSON.stringify(resp))) | ||
.then(resp => setTimeout(() => messageCallback(JSON.stringify(resp)))) | ||
.catch(err => messageCallback(JSON.stringify(unknownError(err, parsedRequest)))); | ||
@@ -21,0 +21,0 @@ }, |
608746
15985