Android Kotlin Realm Правильный способ запроса + обновление Async

Question

Недавно я столкнулся с проблемой, в которой у меня в памяти был список объектов RealResult и показывался в представлении. При щелчке пользователя текущий отображаемый элемент должен быть помечен как удаленный в области (свойство isDeleted)

Итак, я просто получил этот объект из ленивого RealmResults, откройте транзакцию и отметьте ее удаленной. Поскольку RealmResults автоматически обновляется, у меня был слушатель изменений, связанный с notifityDataSetChanged. Все отлично работает, кроме этого предупреждения:

Mixing asynchronous queries with local writes should be avoided. Realm will convert any async queries to synchronous in order to remain consistent. Use asynchronous writes instead 

Что является проблематичным, потому что мой список огромен, и я не хочу, чтобы запрос, чтобы стать sync. Я решил это так, что я не знаю, что это правильно. Вместо того, чтобы дать объект элемента к функции обновления, я даю идентификатор объекта, а затем сделать это:

Realm.getDefaultInstance().use { realm -> 

      realm.executeTransactionAsync { 
       // find the item 
       realm.where(ItemRealm::class.java) 
         .equalTo(ItemRealm.ID, itemId).findFirstAsync() 
         .addChangeListener(object : RealmChangeListener<ItemRealm> { 
          override fun onChange(element: ItemRealm) { 
           element.deleted = true 
           element.removeChangeListener(this) 
          } 
         }) 
      } 
     } 

Проблемой, с которой им не уверен, является async части запроса внутри транзакций асинхронных.

Редактировать. На самом деле, он бросает java.lang.IllegalStateException: Realm access from incorrect thread. Realm objects can only be accessed on the thread they were created.

Edit2: Пробовал это и показать доступ Realm на другом потоке:

fun setItemDeleted(itemId: Long) { 
     // write so new realm instance 
     Realm.getDefaultInstance().use { realm -> 
      realm.executeTransactionAsync { 
       // find the item 
       val item = realm.where(ItemRealm::class.java) 
         .equalTo(ItemRealm.TIMESTAMP, itemId).findFirst() 
       item?.userDeleted = true 
      } 
     } 
    } 

Answer 1

Все в executeTransactionAsync() работает на фоне потока, так что вы должны использовать синхронные методы, чтобы получить ваш объект внутри него ,

Realm.getDefaultInstance().use { realm -> 
    realm.executeTransactionAsync { bgRealm -> 
     // find the item 
     val item = bgRealm.where(ItemRealm::class.java) 
         .equalTo(ItemRealm.ID, itemId).findFirst() 
     item?.deleted = true 
    } 
}