Skip to content

A
AloqaIM-Android
Commit 8eb83aad authored by Yusuke Iwaki's avatar Yusuke Iwaki
Browse files
Options

add debug log

parent e0bc873d
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 0 deletions
app/src/main/java/chat/rocket/android/service/RocketChatWebSocketThread.java
View file @ 8eb83aad
...@@ -212,6 +212,7 @@ public class RocketChatWebSocketThread extends HandlerThread { ...@@ -212,6 +212,7 @@ public class RocketChatWebSocketThread extends HandlerThread {
return checkIfConnectionAlive() return checkIfConnectionAlive()
.doOnSuccess(alive -> { .doOnSuccess(alive -> {
if (!alive) { if (!alive) {
RCLog.d("DDPClient#create");
ddpClient = DDPClientWrapper.create(hostname); ddpClient = DDPClientWrapper.create(hostname);
} }
}); });
...@@ -221,6 +222,7 @@ public class RocketChatWebSocketThread extends HandlerThread { ...@@ -221,6 +222,7 @@ public class RocketChatWebSocketThread extends HandlerThread {
return prepareDDPClient() return prepareDDPClient()
.flatMap(_val -> Single.fromEmitter(emitter -> { .flatMap(_val -> Single.fromEmitter(emitter -> {
ServerInfo info = connectivityManager.getServerInfoForHost(hostname); ServerInfo info = connectivityManager.getServerInfoForHost(hostname);
RCLog.d("DDPClient#connect");
ddpClient.connect(info.session, !info.insecure) ddpClient.connect(info.session, !info.insecure)
.onSuccessTask(task -> { .onSuccessTask(task -> {
final String newSession = task.getResult().session; final String newSession = task.getResult().session;
......
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

Technounit-GROUP 2023