Tag: rx java

RxJava: "java.lang.IllegalStateException: Sólo un suscriptor permitido!"

Estoy usando RxJava para calcular la correlación automática normalizada sobre algunos datos de sensores en Android. Curiosamente, mi código lanza una excepción ("java.lang.IllegalStateException: Sólo se permite un suscriptor!") Y no estoy seguro de qué hacer con él: sé que GroupedObservables podría lanzar esta excepción al suscribirse a mis múltiples suscriptores, pero No creo que esté […]

Comprensión de flujos de datos y múltiples suscriptores (con retroadaptación)

Digamos que tengo 2 Observables (A & B) que son esencialmente llamadas de red (usando Retrofit para dar contexto). El flujo actual de la aplicación es el siguiente: A & B se ponen en marcha casi al mismo tiempo (asincrónicamente). B se ejecuta 0 o más veces en la interacción del usuario Tengo 3 escenarios […]

convertir a lambda de rx java expresión

He comenzado a grok en retrolambda y rxjava. Algunas expresiones i'v convertido por mí mismo, pero algunos de ellos no puedo convertir. He añadido retrolambda a mi proyecto.Aquí hay ejemplos public Observable<ImmutableList<Repository>> getUsersRepositories() { return githubApiService.getUsersRepositories(user.login) .map(repositoryResponses -> { final ImmutableList.Builder<Repository> listBuilder = ImmutableList.builder(); for (RepositoryResponse repositoryResponse : repositoryResponses) { Repository repository = new Repository(); […]

La comprensión incorrecta del búfer en RxJava

Estoy tratando de familiarizarme con RxJava. Aquí está el caso de uso que estoy tratando de lograr: Tengo un botón en mi pantalla y estoy tratando de recoger el número de grifos. Así que si un usuario pulsa el botón, se registra un clic y se produce un registro. Ahora, si el usuario hace clic […]

¿Por qué necesita onBackpressure () aquí para eventos de clic?

Estoy tratando de hacer el manejo de errores para alguna acción vinculada a los clics de botón. Para el enlace uso RxAndroid + RxAndroid. Parece que debe trabajar con el código de abajo, pero no con la línea comentada con onBackpressure() : CurrentUser signIn() { throw new RuntimeException(); } Integer x = 1; PublishSubject<Throwable> loginingFailedSubject […]

Utilizar RxJava para encadenar la solicitud en un solo hilo

Estoy guardando la ubicación del usuario en la base de datos local de la aplicación y luego la envío al servidor. Una vez que el servidor devuelve un éxito, elimino la ubicación que se envió. Cada vez que un punto se ha guardado en la base de datos llamo a este método: public void sendPoint(){ […]

Retrofit2 y kotlin

Estoy tratando de combinar Kotlin RxJava y retrofit2. @GET("/xxxxxxxxxxxx/{id}.json") fun getHotel(@Part("id") id : String) : Observable<Response<Hotel>> Cuando intento llamar a este método (getHotels ()): var subscription = HotelsFactory.getHotelService((activity.applicationContext as App) .client) .getHotel(arguments.getInt("id").toString()) .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe({response -> showHotels(response)}) {throwable -> throwable.printStackTrace()} mSubscription.add(subscription) Tomo este: Los parámetros @Part solo se pueden usar con codificación multipart.

RxJava – subir archivos secuencialmente – emitir el siguiente elemento, cuando onNext llamado

Tengo un método que carga simultáneamente varios archivos en el almacenamiento en la nube. Parece algo como esto: List<String> files = Arrays.asList("file0", "file1", "file2"); Observable.from(files) .flatMap(file -> uploadFile(file) .flatMap(done -> notifyFinished(file))) .subscribe(this::onNext, this::onError, this::onCompleted); private Observable<Boolean> uploadFile(String file) { Timber.d("Uploading: " + file); return Observable.just(true).delay(6, TimeUnit.SECONDS); } private Observable<Boolean> notifyFinished(String file) { Timber.d("Notify finished: " […]

¿Cómo puedo hacer que este zip rxjava funcione en paralelo?

Tengo un método de sueño para simular un proceso de larga ejecución. private void sleep() { try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } } Entonces tengo un método devuelve un Observable que contiene una lista de 2 cadenas que se da en los parámetros. Llama al sueño antes de devolver las cuerdas. […]

No encontró la clase rx.android.schedulers.AndroidSchedulers

Estoy usando rxjava / rxandroid y jackson-databind en mi aplicación pero parece que las dos bibliotecas no pueden trabajar juntas. Cuando intento ejecutar mi aplicación devuelve el error siguiente: java.lang.ClassNotFoundException: rx.android.schedulers.AndroidSchedulers Aquí está mi archivo gradle: apply plugin: 'com.android.application' android { compileSdkVersion 23 buildToolsVersion "23.0.2" defaultConfig { applicationId "myapp" minSdkVersion Integer.parseInt(project.ANDROID_MIN_SDK_VERSION) targetSdkVersion 23 versionCode 1 […]

FlipAndroid es un fan de Google para Android, Todo sobre Android Phones, Android Wear, Android Dev y Aplicaciones para Android Aplicaciones.