Articles of rx java

flatZip dans RxJava

Je zippe plusieurs observables ensemble, puis je les transforme pour obtenir un observable: final Observable<Observable> result = Observable.zip(obs1, obs2, transformFunc); Ce que j’aimerais pouvoir faire, c’est: final Observable result = Observable.flatZip(obs1, obs2, transformFunc); Quel est le moyen le plus propre de le faire, étant donné que flatZip n’existe pas (je devrais peut-être en soumettre un). […]

RxJava FlatMap: Comment faire pour éviter les erreurs?

Dans la chaîne obs1.flatmap(x -> obs2()).subscribe(sub) si obs2 génère une erreur, cela provoque un appel immédiat de onError sur sub . Ceci est comme documenté: Notez que si l’un des observables mappé aux éléments de la source Observable by flatMap abandonne en invoquant onError, l’observable produit par flatMap sera immédiatement annulé et invoquera onError. Mais […]

Quelle est la différence entre les stream réactifs et réactifs?

J’essaie de comprendre la différence entre les stream réactif et réactif, en particulier dans le contexte de RxJava? Le mieux que j’ai pu comprendre, c’est que Reactive Streams a une certaine notion de contrepression dans la spécification, mais que cela existe déjà dans RxJava / Reactive avec l’interface request(n) . Cela ne dérangerait pas une […]

Comment implémenter l’équivalent RxJava d’INotifyPropertyChanged pour créer un modèle de données Observable?

Je suis nouveau sur Java et nouveau sur Rx. Je suis au plus profond. Je suis à un stade précoce d’écriture d’une application Android qui utilisera un modèle MVC (Model-View-Controller) et j’expérimente différentes façons de le faire, notamment RxJava. Mon idée est de faire de mon modèle un Observable et de ma vue un Observer […]

Donner à un observable RxJava quelque chose à émettre par une autre méthode

J’ai une variable dans un fragment dont la valeur changera plusieurs fois au cours de sa vie. Elle est déclenchée par des interactions avec l’interface utilisateur. J’ai donc pensé qu’il serait judicieux d’utiliser un observable pour le conserver, plutôt que de créer toutes les vues à mettre à jour sous forme de champs et de […]

RxJava partage les émissions d’un observable entre plusieurs abonnés

J’ai le problème suivant: J’ai une observable qui fait du travail, mais d’autres observables ont besoin du résultat de cette observable pour fonctionner. J’ai essayé de m’abonner plusieurs fois sur le même observable, mais à l’intérieur du journal, je constate que l’observable d’origine est lancé plusieurs fois. c’est mon observable qui crée l’object: Observable.create((Observable.OnSubscribe) subscriber […]

RxJava – émet une observable chaque seconde

Je fais une timer dans Android en utilisant RxJava. J’ai besoin de faire une timer dans RxJava pour émettre une observable chaque seconde. J’ai essayé ce qui suit mais sans succès. Des idées sur ce que je fais mal? Observable.interval(1000L, TimeUnit.MILLISECONDS) .timeInterval() .observeOn(AndroidSchedulers.mainThread()) .subscribe({Log.d(LOG_TAG, “&&&& on timer”) })

La collecte d’observables sur une liste ne semble pas émettre la collection en une fois

J’utilise RxJava pour collecter essentiellement la liste des observables émis individuellement et les combiner dans une liste d’observables (essentiellement le contraire de flatMap). Voici mon code: // myEvent.findMemberships() returns an Observable<List> myEvent.findMemberships() .flatMap(new Func1<List, Observable>() { @Override public Observable call(List memberships) { List users = new ArrayList(); for (Membership membership : memberships) { users.add(membership.getUser()); } […]

RxJava: Comment créer un observable fetch une fois et réutilisé?

À chaque lancement d’application, j’ai un Observable de modernisation qui récupère le nom d’utilisateur de l’utilisateur sur un serveur. Je souhaite utiliser cette valeur pour chaque abonné ultérieur, mais il semble que chaque fois que j’appelle subscribe (), la valeur est à nouveau extraite du réseau. Étant donné que le nom d’utilisateur ne devrait pas […]

Ajout d’un pool de threads dans un stream RxJava

Je me demandais si je pouvais utiliser la bibliothèque RxJava pour append de la concurrence dans le cas d’utilisation suivant: Extraire séquentiellement une colonne Ssortingng d’un ResultSet existant avec un Observable personnalisé (quelque chose comme ResultSetObservable.create(resultSet) ) Invoquer un service Web pour chacune de ces valeurs (avec une InvokeWebServiceFunc1<String, Pair>() , par exemple) afin de […]