Tag: RX-JAVA2
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
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