Loading data/src/main/java/com/moez/QKSMS/repository/SyncRepositoryImpl.kt +1 −1 Original line number Original line Diff line number Diff line Loading @@ -162,7 +162,7 @@ class SyncRepositoryImpl @Inject constructor( // Sync recipients // Sync recipients recipientCursor?.use { recipientCursor?.use { val contacts = realm.copyToRealm(getContacts()) val contacts = realm.copyToRealmOrUpdate(getContacts()) val recipients = recipientCursor.map { cursor -> val recipients = recipientCursor.map { cursor -> progress++ progress++ syncProgress.onNext(SyncRepository.SyncProgress.Running(max, progress, false)) syncProgress.onNext(SyncRepository.SyncProgress.Running(max, progress, false)) Loading Loading
data/src/main/java/com/moez/QKSMS/repository/SyncRepositoryImpl.kt +1 −1 Original line number Original line Diff line number Diff line Loading @@ -162,7 +162,7 @@ class SyncRepositoryImpl @Inject constructor( // Sync recipients // Sync recipients recipientCursor?.use { recipientCursor?.use { val contacts = realm.copyToRealm(getContacts()) val contacts = realm.copyToRealmOrUpdate(getContacts()) val recipients = recipientCursor.map { cursor -> val recipients = recipientCursor.map { cursor -> progress++ progress++ syncProgress.onNext(SyncRepository.SyncProgress.Running(max, progress, false)) syncProgress.onNext(SyncRepository.SyncProgress.Running(max, progress, false)) Loading