Commit d1bcc7c5 authored by Yusuke Iwaki's avatar Yusuke Iwaki Committed by GitHub

Merge pull request #179 from RocketChat/fix_okhttp_error_notification

fix issue that sendMessage error not notified properly
parents d13702d9 bcf0fe2e
...@@ -134,6 +134,8 @@ public class DDPClientImpl { ...@@ -134,6 +134,8 @@ public class DDPClientImpl {
})); }));
addErrorCallback(subscriptions, task); addErrorCallback(subscriptions, task);
} else {
task.trySetError(new DDPClientCallback.Closed(client));
} }
} }
...@@ -174,6 +176,8 @@ public class DDPClientImpl { ...@@ -174,6 +176,8 @@ public class DDPClientImpl {
})); }));
addErrorCallback(subscriptions, task); addErrorCallback(subscriptions, task);
} else {
task.trySetError(new DDPClientCallback.Closed(client));
} }
} }
...@@ -202,6 +206,8 @@ public class DDPClientImpl { ...@@ -202,6 +206,8 @@ public class DDPClientImpl {
})); }));
addErrorCallback(subscriptions, task); addErrorCallback(subscriptions, task);
} else {
task.trySetError(new DDPClientCallback.Closed(client));
} }
} }
...@@ -241,6 +247,8 @@ public class DDPClientImpl { ...@@ -241,6 +247,8 @@ public class DDPClientImpl {
})); }));
addErrorCallback(subscriptions, task); addErrorCallback(subscriptions, task);
} else {
task.trySetError(new DDPClientCallback.Closed(client));
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment