rx-java

0La chaleur

1Répondre

RxJava: Comment rendre observable à créer sur un thread différent du thread principal

Je souhaite que le code observable s'exécute sur un thread différent du thread principal. Comment puis-je faire cela, je fais comme ceci: Observable operationObservable = Observable.create(new Observa

0La chaleur

2Répondre

Java Observable pour lancer une erreur si elle se produit

Y at-il un moyen d'avoir un Observable juste jeter une exception qui se produit dans une fonction comme flatMap()? En Java, une fonction normale, vous pouvez spécifier qu'il peut lancer une exception:

0La chaleur

1Répondre

Séquence synchrone utilisant RxJava

Je suis en train de me battre pour exprimer ce qui suit avec RxJava. Imaginons que j'avoir un flux de la liste des paquets que je veux transmettre sur un réseau: PublishSubject<List<Packet>> packetsSu

0La chaleur

1Répondre

Essayer d'injecter à une classe d'emploi

J'ai un composant réseau dans mon application qui me permet d'injecter retrofit à mes activités & fragments, je voulais injecter à ma classe d'emploi, voici ce que je l'ai fait Interface NetComponent

0La chaleur

1Répondre

RxJava timeout sans se désabonner de la source

Je suis abonné à chaud observable, puis en appliquant opérateur timeout à elle, mais je ne veux pas se désabonner lorsque TimeoutException est levé, produire uniquement un élément spécial (Je sais que

5La chaleur

1Répondre

Asynchronous, composable valeur de retour pour les données vecteur/flux en Java 9

Dire que j'ai une API qui, en fonction de certains critères de requête, trouveront ou construire un widget: Widget getMatchingWidget(WidgetCriteria c) throws Throwable Le code client (synchrone) reg

2La chaleur

1Répondre

Comment la valeur String est-elle transmise à la méthode updateText()?

Bricoler RxJava pour la première fois, j'ai créé une chaîne Rx pour écouter un changement d'état de l'objet Chaîne: observable=Observable .defer(new Callable<ObservableSource<String>>() { @O

0La chaleur

2Répondre

Retrofit2 traitement de réponse parallèle avec observables

Je travaille sur une application où un utilisateur peut modifier son profil après l'enregistrement. Le problème est que la modification du profil utilise plusieurs appels d'API au backend. Un pour édi

1La chaleur

1Répondre

RxJava: Sachez quand l'observation est terminée et renvoyez Boolean Observable à l'appelant

Je suis nouveau à RxJava. Mon expérience est principalement de ces tutoriels: Here, et here. Maintenant, je me suis retrouvé dans une situation où j'ai appel API avec Retrofit2 qui retournera un Obesr

1La chaleur

2Répondre

Mettre à jour et conserver les données existantes avec RxJava

Je cherche à convertir une certaine logique dans mon application (Android) pour utiliser RxJava, mais j'ai du mal à trouver un moyen de faire de la logique plus avancée. Le cas d'utilisation est le su