Commit 789911dd authored by Leonardo Aramaki's avatar Leonardo Aramaki

Register SessionObserver first for performance gain on loading missed messages

parent 8af265c7
...@@ -55,7 +55,6 @@ public class RocketChatWebSocketThread extends HandlerThread { ...@@ -55,7 +55,6 @@ public class RocketChatWebSocketThread extends HandlerThread {
ActiveUsersSubscriber.class, ActiveUsersSubscriber.class,
UserDataSubscriber.class, UserDataSubscriber.class,
MethodCallObserver.class, MethodCallObserver.class,
SessionObserver.class,
LoadMessageProcedureObserver.class, LoadMessageProcedureObserver.class,
GetUsersOfRoomsProcedureObserver.class, GetUsersOfRoomsProcedureObserver.class,
NewMessageObserver.class, NewMessageObserver.class,
...@@ -368,6 +367,9 @@ public class RocketChatWebSocketThread extends HandlerThread { ...@@ -368,6 +367,9 @@ public class RocketChatWebSocketThread extends HandlerThread {
@DebugLog @DebugLog
private void createObserversAndRegister() { private void createObserversAndRegister() {
SessionObserver sessionObserver = new SessionObserver(appContext, hostname, realmHelper);
sessionObserver.register();
listeners.add(sessionObserver);
for (Class clazz : REGISTERABLE_CLASSES) { for (Class clazz : REGISTERABLE_CLASSES) {
try { try {
Constructor ctor = clazz.getConstructor(Context.class, String.class, RealmHelper.class); Constructor ctor = clazz.getConstructor(Context.class, String.class, RealmHelper.class);
......
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