¿Es correcto lo que estoy haciendo con respecto a Rxjava3 en android?
Publicado por Agustin (1 intervención) el 27/06/2021 16:51:15
Estoy implementando Rxjava3 para android junto con la biblioteca de persistencia ROOM. el codigo funciona, es decir, se conecta a la base de datos y ejecuta un insert. Mi duda es: por un lado si lo estoy haciendo correctamente ya que no comprendo bien el uso de RXjava3. y por otro lado no se que debo colocar en Suscribe() para recibir los datos del flowable.
como les decía, el codigo funciona. pero no se si es la manera adecuada de hacerlo. Espero sus sugerencias, desde ya muchas gracias!
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_huertas);
Flowable.fromCallable(this::conectDb)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(//NO SE QUE DEBO COLOCAR AQUI PARA RECIBIR EL return);
}private String conectDb() {
dB = Room.databaseBuilder(getApplicationContext(),
AppDatabase.class, Config.DB_NAME).build();
HuertaEntity nuevaHuerta = new HuertaEntity("esta es la desc", "esta es la ubi");
dB.huertaDAO().insert(nuevaHuerta);
return "conectada!";}Valora esta pregunta
0