Tag: RX-JAVA
Encuentro la manera correcta de usar rxJava en Android y veo muchos ejemplos como public class MainActivity extends AppCompatActivity { <pre><code>CompositeDisposable compositeDisposable = new CompositeDisposable(); @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); compositeDisposable.add(Single.fromCallable( () -> { //some work here return “resultado de algún trabajo”; }) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(r -> . . . Read more
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
Las llamadas a la API deben realizarse aproximadamente unas 30 veces y solo difieren en un parámetro: https://api.website.com/getProducts?category_id=10 https://api.website.com/getProducts?category_id=11 Estas llamadas responden con un límite de 100 productos por llamada. Si una categoría tiene más productos, necesito añadir un parámetro de desplazamiento. La siguiente llamada me dará el subconjunto de . . . Read more
Quiero saber la diferencia entre retryUntil y retryWhen en RXJava. Tengo un botón llamado Retry y cuando el usuario hace clic en él, la conexión debe volver a intentar obtener datos del servidor. ¿Cuál es la mejor manera de hacerlo? No hay código porque solo quiero saber cuál es el . . . Read more
Estoy tratando de averiguar cómo llamar a un punto final que acepta un parámetro @Body de Flowable<Integer>, para suscribirse y procesar el flujo entrante (usando Micronaut y el marco RxJava). Tengo este controlador en Micronaut: @Post(uri = “inner”) @ExecuteOn(TaskExecutors.IO) HttpResponse inner(@Body Flowable<Integer> template){ template.subscribe(new Subscriber<Integer>() { Subscription subscription @Override void . . . Read more