Tag: rx java

RxJava et Sqlbrite – quel opérateur utiliser

J'ai commencé à utiliser RxJava en combinaison avec SqlBrite et j'ai des problèmes avec l'opérateur zip . Disons que j'ai 2 cours, User et Tweet . public class User { public long id; public List<Tweet> users; … } public class Tweet { public long id; public User poster; … } Et leurs tables SQLite respectives: […]

Comment nettoyer le feu RxJava et oublier les abonnements?

J'ai un feu et oublie les opérations qui ne prennent pas très longtemps, mais assez longtemps que je voulais les exécuter en arrière-plan de manière réactive. La durée de vie est essentiellement alors que la connexion au serveur existe ou que 10 secondes se sont écoulées. Je ne sais pas comment les stocker afin que […]

Comment afficher le spinner si RxJava observable prend longtemps?

J'ai l'impression que quelqu'un doit avoir essayé cela, mais je ne peux pas trouver une bonne façon de faire quelque chose si un observable prend longtemps. C'est le flux que je veux. Start a search. If the search takes longer than some time, show a spinner or show progress bar. When finished do subscription action […]

Comment émettre des éléments d'une liste avec retard dans RxJava?

J'utilise l'option Rétrofit pour obtenir des favoris de l'API REST: public interface BookmarkService { @GET("/bookmarks") Observable<List<Bookmark>> bookmarks(); } Maintenant, j'aimerais émettre chaque article de cette liste avec retard. J'ai fait quelque chose de semblable à cela en Java, mais onCompleted n'est jamais déclenché. private Observable<Bookmark> getBookmarks() { return getBookmarkService().bookmarks() .flatMap(new Func1<List<Bookmark>, Observable<Bookmark>>() { @Override public […]

Services de rétrofit en chaîne avec support RxJava

J'ai du mal à encadrer des observables en utilisant le support RxJava de Retrofit. Je suis probablement mal compris comment l'utiliser, sinon cela pourrait être un bug dans la rénovation. J'espère que quelqu'un ici peut m'aider à comprendre ce qui se passe. Edit: J'utilise MockRestAdapter pour ces réponses – cela peut être pertinent car je […]

Android gère la demande multiple rxJava sur le périphérique de rotation

J'utilise MVVM sur l'application Android et je veux gérer les requêtes et rxJava sur la rotation de l'appareil, comment puis-je désactiver la demande après la rotation du périphérique et compter de la dernière demande? C'est mon code simple pour savoir comment puis-je le faire, mais je ne trouve aucun document et n'en ai trouvé de […]

RxJava Android – Load-cache-affichage des données sur les threads appropriés

Je explore le RxJava et son applicabilité à Android, et j'essaie d'implémenter un simple cas d'utilisation de chargement-cache-display, tel que représenté sur le graphique ASCII suivant: ————— — failure –| Load data |– success — | ————— | VV ——————- ————- | Get from cache | | Filter | ——————- ————- | | | V […]

Comment traiter les clics d'article pour une vue de recyclage à l'aide de RxJava

J'étais intéressé à découvrir quelle est la meilleure façon de répondre à un élément, en cliquant sur une vue de recyclage. Normalement, j'ajoute un auditeur onclick () au ViewHolder et transmis les résultats à l'activité / fragment via une interface. J'ai pensé à ajouter un Observable dans le OnBindViewHolder mais je ne veux pas créer […]

Comportement de NextNext et OnComplete

J'ai un Observable qui fait quelque chose sans avoir à émettre de valeur. De même, j'ai une liste d'objets dont je souhaite que l'Observable fonctionne. Donc, pour tous les éléments de cette liste: doSomething () Observable.from(uris) .flatMap(new Func1<Uri, Observable<Void>>() { @Override public Observable<Void> call(Uri uri) { return createDoSomethingObservable(uri); } }) .observeOn(AndroidSchedulers.mainThread()) .subscribeOn(Schedulers.io()) .subscribe(new Observer<Void>() { […]

Utilisation de subscribeOn with Retrofit

Il existe des informations contradictoires sur le moment et le mode d'utilisation de subscribeOn with Retrofit. Voici une réponse qui dit de ne pas utiliser subscribeOn . Voici une réponse qui semble impliquer que subscribeOn n'a pas de bon jeu par défaut. Voici un code d'exemple utilisant subscribeOn . Donc, une fois pour toutes, quand […]

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