preguntar acerca de rx-java

Je travaille sur la mise en réseau pour mon application. J'ai donc décidé d'essayer Square Rénovation. Je vois qu'ils supportent simple Callback @GET("/user/{id}/photo") void getUserPhoto(@Path("id") int id, Callback<Photo> cb); Et RxJava O …

Quelqu'un peut-il expliquer la différence entre Observable, Completable et Single dans RxJava avec des exemples clairs? Dans quel scénario nous utilisons un sur les autres? ... …

@DELETE("/job/deletejob") Observable<JobDeleteResponseModel> jobDelete( @Body JobDeleteRequestModel model); J'obtiens cette erreur: La méthode HTTP Non-body ne peut pas contenir @Body ou @TypedOutput Quelqu'un peut-il m'aider à en sor …

Quand appeler la méthode subscribeWith plutôt que simplement subscribe? Et qu'est-ce que le cas d'utilisation? compositeDisposable.add(get() .observeOn(AndroidSchedulers.mainThread()) .subscribeOn(Schedulers.io()) .subscribe(this::handle …

Je vérifiais la documentation de RXJava et je remarque que les opérateurs concat et merge semblent faire la même chose. J'ai écrit un test de couple pour être sûr. @Test public void testContact() { Observable.concat(Observable.just("Hello"), …

donc je joue avec RX (really cool), et j'ai converti mon api qui accède à une base de données sqlite sous Android pour retourner les observables. donc naturellement un des problèmes que j'ai commencé à essayer de résoudre est, "que faire si je veux …

je cherche à convertir mon application android pour utiliser Rxjava pour les requêtes réseau. J'ai actuellement accès à un service de ce type: getUsersByKeyword(String query, int limit, int offset) d'après ce que j'ai compris, les Observables sont …

je veux demander à une url en utilisant okhttp dans un autre thread (comme le thread IO) et obtenir Response dans le fil principal Android, mais je ne sais pas comment créer un Observable. ... …

lors de L'utilisation D'Observables avec Retrofit, comment gérer une défaillance du réseau? compte tenu de ce code: Observable<GetJobResponse> observable = api.getApiService().getMyData(); observable .doOnNext(new Action1<GetJobRespons …

ceci émettra une tique toutes les 5 secondes. Observable.interval(5, TimeUnit.SECONDS, Schedulers.io()) .subscribe(tick -> Log.d(TAG, "tick = "+tick)); Pour l'arrêter, vous pouvez utiliser Schedulers.shutdown(); mais alors …