Renamed classes (fix typo)

app/src/main/java/chat/rocket/android/api/DDPClientWraper.java → app/src/main/java/chat/rocket/android/api/DDPClientWrapper.java

@@ -17,11 +17,11 @@ import rx.Observable;
 /**
  * DDP client wrapper.
  */
-public class DDPClientWraper {
+public class DDPClientWrapper {
   private final DDPClient ddpClient;
   private final String hostname;
 
-  private DDPClientWraper(String hostname) {
+  private DDPClientWrapper(String hostname) {
     ddpClient = new DDPClient(OkHttpHelper.getClientForWebSocket());
     this.hostname = hostname;
   }
@@ -29,8 +29,8 @@ public class DDPClientWraper {
   /**
    * create new API client instance.
    */
-  public static DDPClientWraper create(String hostname) {
-    return new DDPClientWraper(hostname);
+  public static DDPClientWrapper create(String hostname) {
+    return new DDPClientWrapper(hostname);
   }
 
   /**

app/src/main/java/chat/rocket/android/api/FileUploadingHelper.java

@@ -16,7 +16,7 @@ public class FileUploadingHelper extends MethodCallHelper {
     super(context, serverConfigId);
   }
 
-  public FileUploadingHelper(RealmHelper realmHelper, DDPClientWraper ddpClient) {
+  public FileUploadingHelper(RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     super(realmHelper, ddpClient);
   }
 

app/src/main/java/chat/rocket/android/api/MethodCallHelper.java

@@ -35,7 +35,7 @@ public class MethodCallHelper {
       task -> Task.forResult(new JSONArray(task.getResult()));
   protected final Context context;
   protected final RealmHelper realmHelper;
-  protected final DDPClientWraper ddpClient;
+  protected final DDPClientWrapper ddpClient;
 
   @Deprecated
   /**
@@ -57,7 +57,7 @@ public class MethodCallHelper {
   /**
    * initialize with RealmHelper and DDPClient.
    */
-  public MethodCallHelper(RealmHelper realmHelper, DDPClientWraper ddpClient) {
+  public MethodCallHelper(RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     this.context = null;
     this.realmHelper = realmHelper;
     this.ddpClient = ddpClient;

app/src/main/java/chat/rocket/android/service/Registerable.java → app/src/main/java/chat/rocket/android/service/Registrable.java

@@ -3,7 +3,7 @@ package chat.rocket.android.service;
 /**
  * interface for observer and ddp_subscription.
  */
-public interface Registerable {
+public interface Registrable {
   /**
    * register.
    */

app/src/main/java/chat/rocket/android/service/RocketChatWebSocketThread.java

@@ -11,7 +11,7 @@ import java.util.Iterator;
 import bolts.Continuation;
 import bolts.Task;
 import bolts.TaskCompletionSource;
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.helper.LogcatIfError;
 import chat.rocket.android.helper.TextUtils;
 import chat.rocket.android.log.RCLog;
@@ -60,8 +60,8 @@ public class RocketChatWebSocketThread extends HandlerThread {
   private final String serverConfigId;
   private final RealmHelper defaultRealm;
   private final RealmHelper serverConfigRealm;
-  private final ArrayList<Registerable> listeners = new ArrayList<>();
-  private DDPClientWraper ddpClient;
+  private final ArrayList<Registrable> listeners = new ArrayList<>();
+  private DDPClientWrapper ddpClient;
   private boolean listenersRegistered;
 
   private RocketChatWebSocketThread(Context appContext, String serverConfigId) {
@@ -157,7 +157,7 @@ public class RocketChatWebSocketThread extends HandlerThread {
 
   private void prepareWebSocket(String hostname) {
     if (ddpClient == null || !ddpClient.isConnected()) {
-      ddpClient = DDPClientWraper.create(hostname);
+      ddpClient = DDPClientWrapper.create(hostname);
     }
   }
 
@@ -233,11 +233,11 @@ public class RocketChatWebSocketThread extends HandlerThread {
     for (Class clazz : REGISTERABLE_CLASSES) {
       try {
         Constructor ctor = clazz.getConstructor(Context.class, String.class, RealmHelper.class,
-            DDPClientWraper.class);
+            DDPClientWrapper.class);
         Object obj = ctor.newInstance(appContext, hostname, serverConfigRealm, ddpClient);
 
-        if (obj instanceof Registerable) {
-          Registerable registerable = (Registerable) obj;
+        if (obj instanceof Registrable) {
+          Registrable registerable = (Registrable) obj;
           registerable.register();
           listeners.add(registerable);
         }
@@ -253,9 +253,9 @@ public class RocketChatWebSocketThread extends HandlerThread {
       return;
     }
 
-    Iterator<Registerable> iterator = listeners.iterator();
+    Iterator<Registrable> iterator = listeners.iterator();
     while (iterator.hasNext()) {
-      Registerable registerable = iterator.next();
+      Registrable registerable = iterator.next();
       registerable.unregister();
       iterator.remove();
     }

app/src/main/java/chat/rocket/android/service/ddp/AbstractDDPDocEventSubscriber.java

@@ -9,25 +9,25 @@ import org.json.JSONException;
 import org.json.JSONObject;
 
 import java.util.Iterator;
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.helper.LogcatIfError;
 import chat.rocket.android.log.RCLog;
 import chat.rocket.android.realm_helper.RealmHelper;
-import chat.rocket.android.service.Registerable;
+import chat.rocket.android.service.Registrable;
 import chat.rocket.android_ddp.DDPSubscription;
 import rx.Subscription;
 
-public abstract class AbstractDDPDocEventSubscriber implements Registerable {
+public abstract class AbstractDDPDocEventSubscriber implements Registrable {
   protected final Context context;
   protected final String hostname;
   protected final RealmHelper realmHelper;
-  protected final DDPClientWraper ddpClient;
+  protected final DDPClientWrapper ddpClient;
   private boolean isUnsubscribed;
   private String subscriptionId;
   private Subscription rxSubscription;
 
   protected AbstractDDPDocEventSubscriber(Context context, String hostname,
-                                          RealmHelper realmHelper, DDPClientWraper ddpClient) {
+                                          RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     this.context = context;
     this.hostname = hostname;
     this.realmHelper = realmHelper;

app/src/main/java/chat/rocket/android/service/ddp/base/AbstractBaseSubscriber.java

@@ -3,13 +3,13 @@ package chat.rocket.android.service.ddp.base;
 import android.content.Context;
 import org.json.JSONArray;
 
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.realm_helper.RealmHelper;
 import chat.rocket.android.service.ddp.AbstractDDPDocEventSubscriber;
 
 abstract class AbstractBaseSubscriber extends AbstractDDPDocEventSubscriber {
   protected AbstractBaseSubscriber(Context context, String hostname, RealmHelper realmHelper,
-                                   DDPClientWraper ddpClient) {
+                                   DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
   }
 

app/src/main/java/chat/rocket/android/service/ddp/base/ActiveUsersSubscriber.java

@@ -3,7 +3,7 @@ package chat.rocket.android.service.ddp.base;
 import android.content.Context;
 import io.realm.RealmObject;
 
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.model.ddp.User;
 import chat.rocket.android.realm_helper.RealmHelper;
 
@@ -12,7 +12,7 @@ import chat.rocket.android.realm_helper.RealmHelper;
  */
 public class ActiveUsersSubscriber extends AbstractBaseSubscriber {
   public ActiveUsersSubscriber(Context context, String hostname, RealmHelper realmHelper,
-                               DDPClientWraper ddpClient) {
+                               DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
   }
 

app/src/main/java/chat/rocket/android/service/ddp/base/LoginServiceConfigurationSubscriber.java

@@ -3,7 +3,7 @@ package chat.rocket.android.service.ddp.base;
 import android.content.Context;
 import io.realm.RealmObject;
 
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.model.ddp.MeteorLoginServiceConfiguration;
 import chat.rocket.android.realm_helper.RealmHelper;
 
@@ -12,7 +12,7 @@ import chat.rocket.android.realm_helper.RealmHelper;
  */
 public class LoginServiceConfigurationSubscriber extends AbstractBaseSubscriber {
   public LoginServiceConfigurationSubscriber(Context context, String hostname,
-                                             RealmHelper realmHelper, DDPClientWraper ddpClient) {
+                                             RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
   }
 

app/src/main/java/chat/rocket/android/service/ddp/base/UserDataSubscriber.java

@@ -3,7 +3,7 @@ package chat.rocket.android.service.ddp.base;
 import android.content.Context;
 import io.realm.RealmObject;
 
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.model.ddp.User;
 import chat.rocket.android.realm_helper.RealmHelper;
 
@@ -12,7 +12,7 @@ import chat.rocket.android.realm_helper.RealmHelper;
  */
 public class UserDataSubscriber extends AbstractBaseSubscriber {
   public UserDataSubscriber(Context context, String hostname, RealmHelper realmHelper,
-                            DDPClientWraper ddpClient) {
+                            DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
   }
 

app/src/main/java/chat/rocket/android/service/ddp/stream/AbstractStreamNotifyEventSubscriber.java

@@ -5,7 +5,7 @@ import org.json.JSONArray;
 import org.json.JSONException;
 import org.json.JSONObject;
 
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.helper.LogcatIfError;
 import chat.rocket.android.log.RCLog;
 import chat.rocket.android.realm_helper.RealmHelper;
@@ -15,7 +15,7 @@ import chat.rocket.android_ddp.DDPSubscription;
 abstract class AbstractStreamNotifyEventSubscriber extends AbstractDDPDocEventSubscriber {
   protected AbstractStreamNotifyEventSubscriber(Context context, String hostname,
                                                 RealmHelper realmHelper,
-                                                DDPClientWraper ddpClient) {
+                                                DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
   }
 

app/src/main/java/chat/rocket/android/service/ddp/stream/AbstractStreamNotifyUserEventSubscriber.java

@@ -2,7 +2,7 @@ package chat.rocket.android.service.ddp.stream;
 
 import android.content.Context;
 
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.realm_helper.RealmHelper;
 
 abstract class AbstractStreamNotifyUserEventSubscriber extends AbstractStreamNotifyEventSubscriber {
@@ -10,7 +10,7 @@ abstract class AbstractStreamNotifyUserEventSubscriber extends AbstractStreamNot
 
   protected AbstractStreamNotifyUserEventSubscriber(Context context, String hostname,
                                                     RealmHelper realmHelper,
-                                                    DDPClientWraper ddpClient, String userId) {
+                                                    DDPClientWrapper ddpClient, String userId) {
     super(context, hostname, realmHelper, ddpClient);
     this.userId = userId;
   }

app/src/main/java/chat/rocket/android/service/ddp/stream/StreamNotifyUserSubscriptionsChanged.java

@@ -5,13 +5,13 @@ import io.realm.RealmObject;
 import org.json.JSONException;
 import org.json.JSONObject;
 
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.model.ddp.RoomSubscription;
 import chat.rocket.android.realm_helper.RealmHelper;
 
 public class StreamNotifyUserSubscriptionsChanged extends AbstractStreamNotifyUserEventSubscriber {
   public StreamNotifyUserSubscriptionsChanged(Context context, String hostname,
-                                              RealmHelper realmHelper, DDPClientWraper ddpClient,
+                                              RealmHelper realmHelper, DDPClientWrapper ddpClient,
                                               String userId) {
     super(context, hostname, realmHelper, ddpClient, userId);
   }

app/src/main/java/chat/rocket/android/service/ddp/stream/StreamRoomMessage.java

@@ -5,7 +5,7 @@ import io.realm.RealmObject;
 import org.json.JSONException;
 import org.json.JSONObject;
 
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.model.ddp.Message;
 import chat.rocket.android.realm_helper.RealmHelper;
 
@@ -16,7 +16,7 @@ public class StreamRoomMessage extends AbstractStreamNotifyEventSubscriber {
   private String roomId;
 
   public StreamRoomMessage(Context context, String hostname,
-                           RealmHelper realmHelper, DDPClientWraper ddpClient, String roomId) {
+                           RealmHelper realmHelper, DDPClientWrapper ddpClient, String roomId) {
     super(context, hostname, realmHelper, ddpClient);
     this.roomId = roomId;
   }

app/src/main/java/chat/rocket/android/service/internal/AbstractRocketChatCacheObserver.java

@@ -7,9 +7,9 @@ import chat.rocket.android.RocketChatCache;
 import chat.rocket.android.helper.TextUtils;
 import chat.rocket.android.model.ddp.RoomSubscription;
 import chat.rocket.android.realm_helper.RealmHelper;
-import chat.rocket.android.service.Registerable;
+import chat.rocket.android.service.Registrable;
 
-public abstract class AbstractRocketChatCacheObserver implements Registerable {
+public abstract class AbstractRocketChatCacheObserver implements Registrable {
   private final Context context;
   private final RealmHelper realmHelper;
   private String roomId;

app/src/main/java/chat/rocket/android/service/internal/StreamRoomMessageManager.java

@@ -4,25 +4,25 @@ import android.content.Context;
 import android.os.Handler;
 import android.os.Looper;
 
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.realm_helper.RealmHelper;
-import chat.rocket.android.service.Registerable;
+import chat.rocket.android.service.Registrable;
 import chat.rocket.android.service.ddp.stream.StreamRoomMessage;
 
 /**
  * wrapper for managing stream-notify-message depending on RocketChatCache.
  */
-public class StreamRoomMessageManager implements Registerable {
+public class StreamRoomMessageManager implements Registrable {
   private final Context context;
   private final String hostname;
   private final RealmHelper realmHelper;
-  private final DDPClientWraper ddpClient;
+  private final DDPClientWrapper ddpClient;
   private final AbstractRocketChatCacheObserver cacheObserver;
   private final Handler handler;
   private StreamRoomMessage streamRoomMessage;
 
   public StreamRoomMessageManager(Context context, String hostname,
-                                  RealmHelper realmHelper, DDPClientWraper ddpClient) {
+                                  RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     this.context = context;
     this.hostname = hostname;
     this.realmHelper = realmHelper;

app/src/main/java/chat/rocket/android/service/observer/AbstractModelObserver.java

@@ -3,22 +3,22 @@ package chat.rocket.android.service.observer;
 import android.content.Context;
 import io.realm.RealmObject;
 
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.realm_helper.RealmHelper;
 import chat.rocket.android.realm_helper.RealmListObserver;
-import chat.rocket.android.service.Registerable;
+import chat.rocket.android.service.Registrable;
 
 abstract class AbstractModelObserver<T extends RealmObject>
-    implements Registerable, RealmListObserver.Query<T>, RealmListObserver.OnUpdateListener<T> {
+    implements Registrable, RealmListObserver.Query<T>, RealmListObserver.OnUpdateListener<T> {
 
   protected final Context context;
   protected final String hostname;
   protected final RealmHelper realmHelper;
-  protected final DDPClientWraper ddpClient;
+  protected final DDPClientWrapper ddpClient;
   private final RealmListObserver observer;
 
   protected AbstractModelObserver(Context context, String hostname,
-                                  RealmHelper realmHelper, DDPClientWraper ddpClient) {
+                                  RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     this.context = context;
     this.hostname = hostname;
     this.realmHelper = realmHelper;

app/src/main/java/chat/rocket/android/service/observer/CurrentUserObserver.java

@@ -6,12 +6,12 @@ import io.realm.RealmResults;
 
 import java.util.ArrayList;
 import java.util.List;
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.api.MethodCallHelper;
 import chat.rocket.android.helper.LogcatIfError;
 import chat.rocket.android.model.ddp.User;
 import chat.rocket.android.realm_helper.RealmHelper;
-import chat.rocket.android.service.Registerable;
+import chat.rocket.android.service.Registrable;
 import chat.rocket.android.service.ddp.stream.StreamNotifyUserSubscriptionsChanged;
 import hugo.weaving.DebugLog;
 
@@ -21,10 +21,10 @@ import hugo.weaving.DebugLog;
 public class CurrentUserObserver extends AbstractModelObserver<User> {
   private final MethodCallHelper methodCall;
   private boolean currentUserExists;
-  private ArrayList<Registerable> listeners;
+  private ArrayList<Registrable> listeners;
 
   public CurrentUserObserver(Context context, String hostname,
-                             RealmHelper realmHelper, DDPClientWraper ddpClient) {
+                             RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
     methodCall = new MethodCallHelper(realmHelper, ddpClient);
     currentUserExists = false;
@@ -61,7 +61,7 @@ public class CurrentUserObserver extends AbstractModelObserver<User> {
     // get and observe Room subscriptions.
     methodCall.getRoomSubscriptions().onSuccess(task -> {
       if (listeners != null) {
-        Registerable listener = new StreamNotifyUserSubscriptionsChanged(
+        Registrable listener = new StreamNotifyUserSubscriptionsChanged(
             context, hostname, realmHelper, ddpClient, userId);
         listener.register();
         listeners.add(listener);
@@ -73,7 +73,7 @@ public class CurrentUserObserver extends AbstractModelObserver<User> {
   @DebugLog
   private void onLogout() {
     if (listeners != null) {
-      for (Registerable listener : listeners) {
+      for (Registrable listener : listeners) {
         listener.unregister();
       }
     }

app/src/main/java/chat/rocket/android/service/observer/FileUploadingToS3Observer.java

@@ -11,7 +11,7 @@ import java.io.IOException;
 import java.io.InputStream;
 import java.util.List;
 import bolts.Task;
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.api.FileUploadingHelper;
 import chat.rocket.android.helper.LogcatIfError;
 import chat.rocket.android.helper.OkHttpHelper;
@@ -35,7 +35,7 @@ public class FileUploadingToS3Observer extends AbstractModelObserver<FileUploadi
   private FileUploadingHelper methodCall;
 
   public FileUploadingToS3Observer(Context context, String hostname,
-                                   RealmHelper realmHelper, DDPClientWraper ddpClient) {
+                                   RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
     methodCall = new FileUploadingHelper(realmHelper, ddpClient);
 

app/src/main/java/chat/rocket/android/service/observer/FileUploadingWithUfsObserver.java

@@ -9,7 +9,7 @@ import org.json.JSONObject;
 import java.io.InputStream;
 import java.util.List;
 import bolts.Task;
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.api.FileUploadingHelper;
 import chat.rocket.android.helper.LogcatIfError;
 import chat.rocket.android.helper.OkHttpHelper;
@@ -31,7 +31,7 @@ public class FileUploadingWithUfsObserver extends AbstractModelObserver<FileUplo
   private FileUploadingHelper methodCall;
 
   public FileUploadingWithUfsObserver(Context context, String hostname,
-                                      RealmHelper realmHelper, DDPClientWraper ddpClient) {
+                                      RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
     methodCall = new FileUploadingHelper(realmHelper, ddpClient);
 

app/src/main/java/chat/rocket/android/service/observer/GetUsersOfRoomsProcedureObserver.java

@@ -7,7 +7,7 @@ import org.json.JSONObject;
 
 import java.util.List;
 import bolts.Task;
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.api.MethodCallHelper;
 import chat.rocket.android.log.RCLog;
 import chat.rocket.android.model.SyncState;
@@ -23,7 +23,7 @@ public class GetUsersOfRoomsProcedureObserver
   private final MethodCallHelper methodCall;
 
   public GetUsersOfRoomsProcedureObserver(Context context, String hostname,
-                                          RealmHelper realmHelper, DDPClientWraper ddpClient) {
+                                          RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
     methodCall = new MethodCallHelper(realmHelper, ddpClient);
   }

app/src/main/java/chat/rocket/android/service/observer/LoadMessageProcedureObserver.java

@@ -8,7 +8,7 @@ import org.json.JSONObject;
 
 import java.util.List;
 import bolts.Task;
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.api.MethodCallHelper;
 import chat.rocket.android.log.RCLog;
 import chat.rocket.android.model.SyncState;
@@ -24,7 +24,7 @@ public class LoadMessageProcedureObserver extends AbstractModelObserver<LoadMess
   private final MethodCallHelper methodCall;
 
   public LoadMessageProcedureObserver(Context context, String hostname,
-                                      RealmHelper realmHelper, DDPClientWraper ddpClient) {
+                                      RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
     methodCall = new MethodCallHelper(realmHelper, ddpClient);
   }

app/src/main/java/chat/rocket/android/service/observer/MethodCallObserver.java

@@ -6,7 +6,7 @@ import io.realm.RealmResults;
 import org.json.JSONObject;
 
 import java.util.List;
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.helper.CheckSum;
 import chat.rocket.android.helper.LogcatIfError;
 import chat.rocket.android.model.SyncState;
@@ -25,7 +25,7 @@ public class MethodCallObserver extends AbstractModelObserver<MethodCall> {
    * constructor.
    */
   public MethodCallObserver(Context context, String hostname,
-                            RealmHelper realmHelper, DDPClientWraper ddpClient) {
+                            RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
     realmHelper.executeTransaction(realm -> {
       // resume pending operations.

app/src/main/java/chat/rocket/android/service/observer/NewMessageObserver.java

@@ -6,7 +6,7 @@ import io.realm.RealmResults;
 import org.json.JSONObject;
 
 import java.util.List;
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.api.MethodCallHelper;
 import chat.rocket.android.helper.LogcatIfError;
 import chat.rocket.android.log.RCLog;
@@ -22,7 +22,7 @@ public class NewMessageObserver extends AbstractModelObserver<Message> {
   private final MethodCallHelper methodCall;
 
   public NewMessageObserver(Context context, String hostname,
-                            RealmHelper realmHelper, DDPClientWraper ddpClient) {
+                            RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
     methodCall = new MethodCallHelper(realmHelper, ddpClient);
 

app/src/main/java/chat/rocket/android/service/observer/NotificationItemObserver.java

@@ -17,7 +17,7 @@ import java.util.List;
 import bolts.Task;
 import chat.rocket.android.R;
 import chat.rocket.android.activity.MainActivity;
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.helper.Avatar;
 import chat.rocket.android.helper.TextUtils;
 import chat.rocket.android.model.ServerConfig;
@@ -31,7 +31,7 @@ import chat.rocket.android.service.notification.NotificationDismissalCallbackSer
  */
 public class NotificationItemObserver extends AbstractModelObserver<NotificationItem> {
   public NotificationItemObserver(Context context, String hostname, RealmHelper realmHelper,
-                                  DDPClientWraper ddpClient) {
+                                  DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
   }
 

app/src/main/java/chat/rocket/android/service/observer/ReactiveNotificationManager.java

@@ -8,7 +8,7 @@ import org.json.JSONException;
 import org.json.JSONObject;
 
 import java.util.List;
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.helper.LogcatIfError;
 import chat.rocket.android.log.RCLog;
 import chat.rocket.android.model.ddp.RoomSubscription;
@@ -20,7 +20,7 @@ import chat.rocket.android.realm_helper.RealmHelper;
  */
 public class ReactiveNotificationManager extends AbstractModelObserver<RoomSubscription> {
   public ReactiveNotificationManager(Context context, String hostname,
-                                     RealmHelper realmHelper, DDPClientWraper ddpClient) {
+                                     RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
   }
 

app/src/main/java/chat/rocket/android/service/observer/SessionObserver.java

@@ -5,7 +5,7 @@ import io.realm.Realm;
 import io.realm.RealmResults;
 
 import java.util.List;
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.api.MethodCallHelper;
 import chat.rocket.android.helper.LogcatIfError;
 import chat.rocket.android.model.ddp.PublicSetting;
@@ -28,7 +28,7 @@ public class SessionObserver extends AbstractModelObserver<Session> {
    * constructor.
    */
   public SessionObserver(Context context, String hostname,
-                         RealmHelper realmHelper, DDPClientWraper ddpClient) {
+                         RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
     count = 0;
 

app/src/main/java/chat/rocket/android/service/observer/TokenLoginObserver.java

@@ -5,7 +5,7 @@ import io.realm.Realm;
 import io.realm.RealmResults;
 
 import java.util.List;
-import chat.rocket.android.api.DDPClientWraper;
+import chat.rocket.android.api.DDPClientWrapper;
 import chat.rocket.android.api.MethodCallHelper;
 import chat.rocket.android.helper.LogcatIfError;
 import chat.rocket.android.model.internal.Session;
@@ -16,7 +16,7 @@ public class TokenLoginObserver extends AbstractModelObserver<Session> {
   private final MethodCallHelper methodCall;
 
   public TokenLoginObserver(Context context, String hostname,
-                            RealmHelper realmHelper, DDPClientWraper ddpClient) {
+                            RealmHelper realmHelper, DDPClientWrapper ddpClient) {
     super(context, hostname, realmHelper, ddpClient);
     methodCall = new MethodCallHelper(realmHelper, ddpClient);
   }