Tag: RX-JAVA
Estoy implementando un listener de SQS reactivo y me enfrento a un problema con las suscripciones anidadas. Así es como se ve mi listener: @PostConstruct public void listener() { Mono<ReceiveMessageResponse> receiveMessageResponseMono = Mono.fromFuture( () -> sqsAsyncClient.receiveMessage( ReceiveMessageRequest.builder() .queueUrl(queueUrl) .maxNumberOfMessages(MAX<em>NUMBER</em>OF<em>MESSAGES) .waitTimeSeconds(WAIT</em>TIME<em>IN</em>SECONDS) .build())); } receiveMessageResponseMono .repeat() .retry() .map(ReceiveMessageResponse::messages) .map(Flux::fromIterable) .flatMap(messageFlux -> messageFlux) . . . Read more
Necesito registrar cosas importantes de la aplicación de Android utilizando la clase Log. Principalmente uso los tipos debug, info y error. Mi problema es que algunos registros se imprimen con bastante frecuencia en el Logcat, por ejemplo, el estado del GPS, la escucha del espacio libre del teléfono, etc. Para . . . Read more
En JavaFX puedo tener una “propiedad” que admite las siguientes operaciones: 1) Obtener el valor de la propiedad 2) Establecer el valor de la propiedad 3) Suscribirse a cambios de la propiedad, etc. Me gustaría utilizar este concepto sin depender de JavaFX y creo que se puede utilizar RxJava. Pensé . . . Read more
Estoy intentando cambiar la versión de destino a Android 12 (S). Pero tengo un error: java.lang.IllegalArgumentException: : Apuntar a S+ (versión 31 o superior) requiere que se especifique FLAG_IMMUTABLE o FLAG_MUTABLE al crear un PendingIntent. Considera seriamente usar FLAG_IMMUTABLE, solo usa FLAG_MUTABLE si alguna funcionalidad depende de que PendingIntent sea . . . Read more
Como indica el título, quiero poder recibir una notificación cada vez que cambie el valor de la llamada Retrofit. ¿Es posible hacerlo llamando este código solo una vez en onCreate()? El escenario es el siguiente: he construido un juego RPG. Por ejemplo, quiero recibir una notificación sobre la cantidad de . . . Read more