es.davy.ai

Preguntas y respuestas de programación confiables

¿Tienes una pregunta?

Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.

Tag: RX-JAVA

RxJava – ¿Cómo llamar el método onError() de .subscribe()?

Tengo un Single.fromCallable() al que estoy suscrito. Utilizando LiveData, estoy intentando probar la manipulación de errores de la interfaz de usuario dentro del método de devolución de llamada onError() de .subscribe(). He intentado lanzar Exceptions, llamar a disposable.dispose(), pero no puedo simular un error para que vaya directamente al bloque . . . Read more

La aplicación se congela por un breve momento al utilizar Retrofit con RxJava.

JSON [ { "countryName":"…" }, { "countryName":"…" }, { "countryName":"…" } //etc… to 195 countries ] Interfaz public interface RetrofitInterface { @GET("GetCountries.php") Single<List<CountryModel>> getCountries(); } Código new Retrofit.Builder().baseUrl(Constants.BASE_URL).addConverterFactory(GsonConverterFactory.create()).addCallAdapterFactory(RxJava3CallAdapterFactory.create()).build().create(RetrofitInterface.class).getCountries().doOnSuccess(countryModels – > { for (CountryModel item: countryModels) { Chip chip = new Chip(requireContext()); chip.setText(item.getCountryName()); fragmentCountriesBinding.fragmentCountriesChipGroupMain.addView(chip); } }).observeOn(AndroidSchedulers.mainThread()).subscribe(new SingleObserver < List < CountryModel . . . Read more

¿Cómo mapeo errores en rxJava?

¿Cómo puedo transformar un error devuelto por un Observable en rxJava? Ahora tengo este método: @Override public Maybe<jsonobject> getUser(String token) { return tokenManager.getTokenInfo(token) //returns a Single<userinfo> .flatMapMaybe(userInfo -> userRepo.findOne(userInfo)); } El comportamiento es que cualquier excepción que sea pasada por getTokenInfo o findOne se propaga al suscriptor del valor de . . . Read more