Commit bcf0fe2e authored by Yusuke Iwaki's avatar Yusuke Iwaki

hotfix: fix issue that sendMessage error not notified properly.

parent d13702d9
...@@ -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