Tag: rx java

Traitement partagé d'objets paginés à l'aide de RxJava

Je suis presque vendu à RxJava, qui est un compagnon parfait pour le réaménagement, mais je me heurte à un modèle commun lors de la migration de mon code: pour économiser de la bande passante, j'aimerais chercher des objets (paginés) de mes services Web au besoin , Alors que mon listview (ou recyclerview) est en […]

Comment déboucher une demande de rétrofit réactive dans java?

Je travaille sur un projet Android qui effectue des demandes par réaménagement en utilisant Rx-Java observable et s'abonner. Cependant, dans certaines interactions, cette requête peut être appelée plusieurs fois et je ne souhaite qu'exécuter la dernière dans une fenêtre de temps prédéfinie (debounce). J'ai essayé d'appliquer l'opérateur de debounce directement à l'observable, mais cela ne […]

Proguard et RxAndroid V1.1.0

Je ne peux pas demander à Proguard de travailler avec la bibliothèque RxAndroid v1.1.0. Auparavant, j'ai utilisé v1.0.1 et cela a bien fonctionné avec la règle suivante. -dontwarn rx.internal.util.unsafe.** Toutefois, après la mise à niveau vers v1.1.0 de rxAndroid et incluant également RxJava tel qu'il l'indique sur le GItu ReadMe.txt, j'obtiens cette exception chaque fois […]

Une file d'attente de tâches d'arrière-plan dans rxjava

Est-il possible d'implémenter une file d'attente de tâches en arrière-plan à l'aide de rxjava? J'ai besoin d'ajouter une tâche à tout moment et une seule tâche exécutée simultanément. J'ai essayé PublishSubject , mais lorsque je PublishSubject exécution sur le nouveau thread observeOn(Schedulers.newThread()) il démarre plus d'une tâche à l'heure. MISE À JOUR: Est-il possible de […]

RxJava comme bus d'événement?

Je commence à apprendre RxJava et j'aime ça jusqu'à présent. J'ai un fragment qui communique avec une activité au clic de bouton (pour remplacer le fragment actuel par un nouveau fragment). Google recommande l' interface pour que les fragments puissent communiquer avec l'activité, mais c'est trop prononcé, j'ai essayé d'utiliser un récepteur de diffusion qui […]

Comment créer un Observable dans Android?

Ce que je veux faire, c'est de créer un cache en mémoire simple uniquement pour essayer Observables. Cependant, je me suis coincé parce que je ne comprends pas comment créer un observable. C'est le code que j'ai obtenu jusqu'ici: public class MovieCache { MovieWrapper movieWrapper; public Observable<MovieWrapper> getMovies() { //How to create and return an […]

Combinaison de l'auditeur de données en temps réel Firebase avec RxJava

J'utilise Firebase dans mon application, avec RxJava. Firebase est capable d'avertir votre application chaque fois que quelque chose a changé dans les données du backend (ajout, suppression, modification, …). J'essaie de combiner la fonctionnalité de Firebase avec RxJava. Les données que LeisureUpdate sont appelées Leisure , et l' Observable émet LeisureUpdate qui contient un Leisure […]

Kotlin: Qu'est-ce que "return @" signifie?

J'utilise RxJava dans l'un de mes projets, j'ai converti une de mes classes en Kotlin en utilisant le plugin Android Studio et dans l'une des cartes flatMap lambda (Func1 in java), les retours intermédiaires ressemblent à la suivante @Func1 . Je n'ai aucune idée de ce que cela signifie. something.flatMap(Func1<ArticleCriteria, Observable<Pair<String, String>>> { val isTemporaryClone […]

Pourquoi RxJava avec rétrofit sur Android doOnError () ne fonctionne pas mais l'abonné onError ne fonctionne pas

Quelqu'un peut-il m'expliquer pourquoi un code comme celui-ci? networApi.getList() .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .doOnError(throwable -> { throwable.getMessage(); }) .doOnNext(list -> { coursesView.populateRecyclerView(list); courseList = (List<Course>) courses; }).subscribe(); S'il n'y a pas d'Internet dans doOnError mais le lance plus loin, l'application descend, mais codez comme ceci: networkApi.getList() .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Subscriber<List<? extends Course>>() { @Override public void onCompleted() […]

Observable.empty () provoque java.util.NoSuchElementException: La séquence ne contient aucun élément

J'utilise Retrofit 2.0.0-beta2 avec RxJava 1.0.14. Je manipule les erreurs de cette façon car j'ai besoin d'exécuter un certain code dans doFinally: .onErrorResumeNext(Observable.empty()); Mais quand je reçois une réponse HTTP avec une erreur (401 par exemple), mon application se bloque sans mes classes dans la trace de la pile. Rien de mal ne se produit […]

coAndroid est un fan Android de Google, tout sur les téléphones Android, Android Wear, Android Dev et Android Games Apps.