Tag: RX-ANDROID
Tengo un observable encadenado que he creado de la siguiente manera: Disposable disposable = currentUsedAdapter.connect(ip) .observeOn(AndroidSchedulers.mainThread()) .concatMap(fallbackAdapter(ProtocolType.V2)) .delay(500, TimeUnit.MILLISECONDS) .concatMap(fallbackAdapter(ProtocolType.V1)) .subscribeWith(connectionSubscriber); Y este es el método fallbackAdapter: private Function<boolean,></boolean,><boolean>> fallbackAdapter(ProtocolType protocolType) { return new Function<boolean,></boolean,><boolean>>() { @Override public Observable<boolean> apply(@NonNull Boolean isConnected) throws Exception { if (isConnected) { return Observable.just(true); . . . Read more
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
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
El código original en español sería: SingleObserver <responsebody> singleObserver = new SingleObserver <responsebody> () { @Override public void onSubscribe(@io.reactivex.rxjava3.annotations.NonNull Disposable d) { Log.w(“ABC”, “S”); } @Override public void onSuccess(@io.reactivex.rxjava3.annotations.NonNull ResponseBody responseBody) { try { Log.w(“ABC”, responseBody.string()); } catch (IOException e) { e.printStackTrace(); } } @Override public void onError(@io.reactivex.rxjava3.annotations.NonNull Throwable e) . . . Read more
Tengo este tipo de respuesta de error. { “success”: false, “code”: 400, “message”: “Error de validación.”, “data”: { “mobile”: [ “El móvil ya ha sido registrado.” ] } } Esta es mi clase pojo. class LoginResponse { @SerializedName(“success”) val isSuccess = false @SerializedName(“code”) val responseCode = 0 @SerializedName(“message”) lateinit var . . . Read more