remove requests when done
This commit is contained in:
+3
-2
@@ -93,10 +93,11 @@ object BrowserExtensionFeature {
|
|||||||
} else if (type == "turndown") {
|
} else if (type == "turndown") {
|
||||||
val requestId = messageJSON.getInt("id")
|
val requestId = messageJSON.getInt("id")
|
||||||
val status = messageJSON.getString("status")
|
val status = messageJSON.getString("status")
|
||||||
|
val handler = requestHandlers.remove(requestId)
|
||||||
if (status == "success") {
|
if (status == "success") {
|
||||||
requestHandlers[requestId]?.success(message)
|
handler?.success(message)
|
||||||
} else {
|
} else {
|
||||||
requestHandlers[requestId]?.error(
|
handler?.error(
|
||||||
"Pref Manager",
|
"Pref Manager",
|
||||||
"Failed to perform operation",
|
"Failed to perform operation",
|
||||||
message.getString("error")
|
message.getString("error")
|
||||||
|
|||||||
+3
-2
@@ -97,10 +97,11 @@ object ContainerProxyFeature {
|
|||||||
if (type == "healthcheck") {
|
if (type == "healthcheck") {
|
||||||
val requestId = messageJSON.getInt("id")
|
val requestId = messageJSON.getInt("id")
|
||||||
val status = messageJSON.getString("status")
|
val status = messageJSON.getString("status")
|
||||||
|
val handler = requestHandlers.remove(requestId)
|
||||||
if (status == "success") {
|
if (status == "success") {
|
||||||
requestHandlers[requestId]?.success(message)
|
handler?.success(message)
|
||||||
} else {
|
} else {
|
||||||
requestHandlers[requestId]?.error(
|
handler?.error(
|
||||||
"Container Proxy",
|
"Container Proxy",
|
||||||
"Failed to perform operation",
|
"Failed to perform operation",
|
||||||
message.getString("error")
|
message.getString("error")
|
||||||
|
|||||||
+3
-2
@@ -76,10 +76,11 @@ object CookieManagerFeature {
|
|||||||
|
|
||||||
val requestId = messageJSON.getInt("id")
|
val requestId = messageJSON.getInt("id")
|
||||||
val status = messageJSON.getString("status")
|
val status = messageJSON.getString("status")
|
||||||
|
val handler = requestHandlers.remove(requestId)
|
||||||
if (status == "success") {
|
if (status == "success") {
|
||||||
requestHandlers[requestId]?.success(message)
|
handler?.success(message)
|
||||||
} else {
|
} else {
|
||||||
requestHandlers[requestId]?.error(
|
handler?.error(
|
||||||
"Cookie Manager",
|
"Cookie Manager",
|
||||||
"Failed to perform operation",
|
"Failed to perform operation",
|
||||||
message.getString("error")
|
message.getString("error")
|
||||||
|
|||||||
+3
-2
@@ -79,10 +79,11 @@ object MLEngineFeature {
|
|||||||
mutex.withLock {
|
mutex.withLock {
|
||||||
val requestId = messageJSON.getInt("id")
|
val requestId = messageJSON.getInt("id")
|
||||||
val status = messageJSON.getString("status")
|
val status = messageJSON.getString("status")
|
||||||
|
val handler = requestHandlers.remove(requestId)
|
||||||
if (status == "success") {
|
if (status == "success") {
|
||||||
requestHandlers[requestId]?.success(message)
|
handler?.success(message)
|
||||||
} else {
|
} else {
|
||||||
requestHandlers[requestId]?.error(
|
handler?.error(
|
||||||
"ML Engine",
|
"ML Engine",
|
||||||
"Failed to perform operation",
|
"Failed to perform operation",
|
||||||
message.getString("error")
|
message.getString("error")
|
||||||
|
|||||||
+3
-2
@@ -67,10 +67,11 @@ object PrefManagerFeature {
|
|||||||
|
|
||||||
val requestId = messageJSON.getInt("id")
|
val requestId = messageJSON.getInt("id")
|
||||||
val status = messageJSON.getString("status")
|
val status = messageJSON.getString("status")
|
||||||
|
val handler = requestHandlers.remove(requestId)
|
||||||
if (status == "success") {
|
if (status == "success") {
|
||||||
requestHandlers[requestId]?.success(message)
|
handler?.success(message)
|
||||||
} else {
|
} else {
|
||||||
requestHandlers[requestId]?.error(
|
handler?.error(
|
||||||
"Pref Manager",
|
"Pref Manager",
|
||||||
"Failed to perform operation",
|
"Failed to perform operation",
|
||||||
message.getString("error")
|
message.getString("error")
|
||||||
|
|||||||
Reference in New Issue
Block a user