hotfix: fix issue that sendMessage error not notified properly.

bf3519a5 · Yusuke Iwaki · 0e0d18a5 · bf3519a5
Commit bf3519a5 authored Jan 24, 2017 by Yusuke Iwaki
Show whitespace changes
Inline Side-by-side

Showing with 8 additions and 0 deletions

DDPClientImpl.java .../src/main/java/chat/rocket/android_ddp/DDPClientImpl.java +8 -0

No files found.
--- a/android-ddp/src/main/java/chat/rocket/android_ddp/DDPClientImpl.java
+++ b/android-ddp/src/main/java/chat/rocket/android_ddp/DDPClientImpl.java
@@ -130,6 +130,8 @@ public class DDPClientImpl {
              }));

      addErrorCallback(subscriptions, task);
+    } else {
+      task.trySetError(new DDPClientCallback.Closed(client));
    }
  }

@@ -170,6 +172,8 @@ public class DDPClientImpl {
              }));

      addErrorCallback(subscriptions, task);
+    } else {
+      task.trySetError(new DDPClientCallback.Closed(client));
    }
  }

@@ -198,6 +202,8 @@ public class DDPClientImpl {
              }));

      addErrorCallback(subscriptions, task);
+    } else {
+      task.trySetError(new DDPClientCallback.Closed(client));
    }
  }

@@ -237,6 +243,8 @@ public class DDPClientImpl {
              }));

      addErrorCallback(subscriptions, task);
+    } else {
+      task.trySetError(new DDPClientCallback.Closed(client));
    }
  }