Je travaille sur la mise en réseau de mon application. J'ai donc décidé d'essayer Retrofit Square . Je vois qu'ils prennent en charge simpleCallback @GET("/user/{id}/photo") void getUserPhoto(@Path("id") int id, Callback<Photo> cb); et RxJava Observable @GET("/user/{id}/photo")...
Dans RxJava, vous avez le choix entre 5 planificateurs différents : immediate () : crée et renvoie un planificateur qui exécute le travail immédiatement sur le thread actuel. trampoline () : crée et renvoie un planificateur qui met en file d'attente le travail sur le thread en cours à exécuter une...
J'aimerais connaître la différence entre CompletableFuture, Futureet Observable RxJava. Ce que je sais, c'est que tous sont asynchrones mais Future.get() bloque le fil CompletableFuture donne les méthodes de rappel RxJava Observable--- similaire à CompletableFutured'autres avantages (pas sûr) Par...
Quand utilisez-vous mapvs flatMapdans RxJava ? Disons, par exemple, que nous voulons mapper les fichiers contenant JSON en chaînes qui contiennent le JSON-- En utilisant map, nous devons faire face en Exceptionquelque sorte. Mais comment?: Observable.from(jsonFile).map(new Func1<File,...
La définition rxjava doc de switchmap est assez vague et renvoie à la même page que flatmap. Quelle est la différence entre les deux
Les flux Java 8 sont-ils similaires aux observables RxJava? Définition du flux Java 8: Les classes du nouveau java.util.streampackage fournissent une API Stream pour prendre en charge les opérations de style fonctionnel sur les flux d'éléments.
J'ai regardé le nouveau rx java 2 et je ne suis pas tout à fait sûr de comprendre l'idée de backpressureplus ... Je sais que nous avons Observablequi n'a pas de backpressuresoutien et Flowablequi en a. Donc, basé sur l'exemple, disons que j'ai flowableavec interval: Flowable.interval(1,...
Quelqu'un peut-il expliquer la différence entre Observable, Completable et Single dans RxJava avec des exemples clairs? Dans quel scénario utilisons-nous l'un sur les
J'essaye de passer à Retrofit 2.0 et d'ajouter RxJava dans mon projet Android. Je fais un appel à l'API et je souhaite récupérer le code d'erreur en cas de réponse d'erreur du serveur. Observable<MyResponseObject> apiCall(@Body body); Et dans l'appel RxJava:
Je vais envoyer une méthode get simple à mon serveur (c'est l'application Rails) et obtenir le résultat en utilisant RxJava et Retrofit. La chose que j'ai faite est: Mon interface: public interface ApiCall { String SERVICE_ENDPOINT = "https://198.50.214.15"; @GET("/api/post")
J'utilise rxjava dans mon application Android pour gérer les demandes réseau de manière asynchrone. Maintenant, je voudrais réessayer une demande réseau ayant échoué seulement après un certain temps. Existe-t-il un moyen d'utiliser retry () sur un observable mais de ne réessayer qu'après un...
TL; DR Comment convertir Task.whenAll(List<Task>)en RxJava? Mon code existant utilise Bolts pour construire une liste de tâches asynchrones et attend que toutes ces tâches se terminent avant d'effectuer d'autres étapes. Essentiellement, il crée un List<Task>et retourne un seul Taskqui...