Debug

src/org/thoughtcrime/securesms/jobs/TypingSendJob.java

@@ -21,9 +21,7 @@ import org.whispersystems.signalservice.api.messages.SignalServiceTypingMessage.
 import org.whispersystems.signalservice.api.push.SignalServiceAddress;
 
 import java.util.Collections;
-import java.util.HashSet;
 import java.util.List;
-import java.util.Set;
 import java.util.concurrent.TimeUnit;
 
 import javax.inject.Inject;
@@ -86,11 +84,11 @@ public class TypingSendJob extends BaseJob implements InjectableType {
       throw new IllegalStateException("Tried to send a typing indicator to a non-existent thread.");
     }
 
-    Set<Recipient> recipients = new HashSet<>(Collections.singletonList(recipient));
+    List<Recipient> recipients = Collections.singletonList(recipient);
     Optional<byte[]> groupId  = Optional.absent();
 
     if (recipient.isGroupRecipient()) {
-      recipients = new HashSet<>(DatabaseFactory.getGroupDatabase(context).getGroupMembers(recipient.getAddress().toGroupString(), false));
+      recipients = DatabaseFactory.getGroupDatabase(context).getGroupMembers(recipient.getAddress().toGroupString(), false);
       groupId    = Optional.of(GroupUtil.getDecodedId(recipient.getAddress().toGroupString()));
     }
 

src/org/thoughtcrime/securesms/notifications/MarkReadReceiver.java

@@ -77,9 +77,10 @@ public class MarkReadReceiver extends BroadcastReceiver {
     for (MarkedMessageInfo messageInfo : markedReadMessages) {
       scheduleDeletion(context, messageInfo.getExpirationInfo());
 
-      if (!SyncMessagesProtocol.shouldSyncReadReceipt(messageInfo.getSyncMessageId().getAddress())) { continue; }
+      if (SyncMessagesProtocol.shouldSyncReadReceipt(messageInfo.getSyncMessageId().getAddress())) {
         syncMessageIds.add(messageInfo.getSyncMessageId());
       }
+    }
 
     ApplicationContext.getInstance(context)
                       .getJobManager()