Tag: RX-JAVA
Estoy tratando de enviar los 128 bytes del bloque al controlador BLE usando la biblioteca RxAndroidBle. El flujo para enviar datos desde el móvil al controlador BLE es el siguiente: Conectar con el controlador BLE Iniciar OTA (enviar 1) Enviar CRC (del bloque de datos) Enviar bloque de datos Esperar . . . Read more
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
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 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
Estoy intentando implementar MVVM usando un SDK de terceros que realiza una consulta para obtener el saldo de una billetera. (No tienen un punto final de API, solo su SDK, por lo que no se utiliza la biblioteca Retrofit) En mi clase “MainRepository”, estoy utilizando uno de sus métodos que . . . Read more