Modo correcto de consulta de Android Kotlin Realm + devolución de elementos no administrados en Bg Thread

¿Cuál es la forma correcta de consultar y devolver un resultado no gestionado de elementos con el reino, todo en el hilo de background ?. Estoy usando algo así:

return Observable.just(1) .subscribeOn(Schedulers.io()) .map { val realm = Realm.getDefaultInstance() val results = realm.where(ItemRealm::class.java) .equalTo("sent", false).findAll() realm to results } .map { val (realm, results) = it val unManagedResults = realm.copyFromRealm(results) realm.close() unManagedResults } } 

Y luego encadenando este observable con otro que publicará los resultados en un server.

• Cómo arreglar "La característica no es parte del esquema para este Reino" en Kotlin Realm Extention
• Basic Realm + Kotlin: RealmObject no está configurando valores pasados
• El tamaño de RealmResults es cero
• Cómo implementar un reciclador de carga perezosa. Adaptador de vista como el reciclador de reino. Ver el adaptador usando kotlin.
• Realm call setter

La solución funciona, aunque es un poco fea en estos aspectos:

• No hay forma adecuada de envolver el realmQuery en un observable, porque no hay forma de abrir una instancia real en un hilo de background sin este tipo de trampa (al less que yo sepa), así que necesito usar este observable falso. Observable.just(1) .

• No es el mejor lugar para abrir y cerrar instancias de Realm, dentro del primer y segundo map

• No sé si se garantiza que la instancia del reino esté cerrada después de que se hayan copydo todos los elementos.

Entonces, ¿cuál es la forma correcta de consultar y devolver los resultados no administrados en el hilo de background (algo de context, necesito esto para enviar los resultados a un server, en segundo plano y esta tarea es totalmente independiente del flujo de datos actual de mi aplicación, por lo que debería estar fuera del hilo principal).

Versión sugerida:

 return Observable.fromCallable { Realm.getDefaultInstance().use { realm -> realm.copyFromRealm( realm.where(ItemRealm::class.java) .equalTo(ItemRealm.FIELD_SEND, false).findAll() ) } } 

  return Observable.defer(() -> { try(Realm realm = Realm.getDefaultInstance()) { return Observable.just( realm.copyFromRealm( realm.where(ItemRealm.class).equalTo("sent", false).findAll() ) ); } }).subscribeOn(Schedulers.io());