Subscribewith Vs abonnez-vous à RxJava2(Android)?

Observables#abonnez-vous explication:

Dans votre premier extrait de code:

.abonnez-vous(c'::handleResponse, ce::handleError));

Vous êtes réellement en utilisant une des plusieurs surchargé Observable#subscribe méthodes:

public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError)

Il y en a une autre qui prend également en un Action pour effectuer onComplete:

public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError,
        Action onComplete) {

Et une autre option vous permet de tout simplement passer une Observer (REMARQUE: la méthode void) (Edition 2 - cette méthode est définie dans ObservableSource, qui est l'interface qui Observable s'étend.)

public final void subscribe(Observer<? super T> observer)

Dans le deuxième extrait de code dans votre question, vous avez utilisé le subscribeWith méthode qui retourne simplement l' Observer passée dans (pratique/mise en cache, etc):

public final <E extends Observer<? super T>> E subscribeWith(E observer)

Observateur#onComplete explication:

Observateur#onComplete est appelé après que l'Observable a émis tous les éléments dans le flux.
De la java doc:

/**
 * Notifies the Observer that the {@link Observable} has finished sending push-based notifications.
 * <p>
 * The {@link Observable} will not call this method if it calls {@link #onError}.
 */
void onComplete();

Ainsi, par exemple, si le get() dans vos extraits de code renvoyé un Observable qui l'a émis plusieurs News objets, chacun sera traité dans le Observer#onNext. Ici vous pouvez traiter chaque élément.

Après qu'ils ont tous été traités (et en supposant qu'aucune erreur ne s'est produite), puis le onComplete sera appelée. Ici vous pouvez effectuer toutes les actions supplémentaires que vous devez faire (pour exemple. mise à jour de l'INTERFACE utilisateur), sachant que vous avez traité tous les News objets.

Ce n'est pas à confondre avec Disposable#dispose qui est appelé lorsque l'observable flux extrémités (complet/erreur), ou manuellement par vous-même pour mettre fin à l'observation (c'est là que le CompositeDisposable vient car il vous aide à vous débarrasser de tous vos Disposables qu'elle contient à la fois).

Si dans votre scénario de la get() sera de retour une Observable qui émet seulement un seul élément, alors au lieu d'utiliser un Observable, envisager l'utilisation d'un io.reactivex.Single où vous ne traiter que d'un point (en onSuccess), et n'aurez pas besoin de spécifier un Action pour onComplete 🙂

Modifier: réponse à votre commentaire:

Cependant je ne comprends toujours pas l'utilisation de subscribeWith, vous avez dit qu'il passe
l'observateur de la mise en cache etc , où faut-il passer? sur complet? et
de ce que j'ai compris subscribeWith n'est pas réellement la consommation de la
observables( ou la Seule) à droite?

De clarifier davantage la subscribeWith explication, ce que je voulais dire, c'est qu'il sera consommer le Observer objet que vous avez passé dans le subscribeWith (exactement comme le subscribe méthode) cependant, il va en outre de retour que même l'Observateur le droit de retour pour vous. Au moment de la rédaction, la mise en œuvre de subscribeWith est:

public final <E extends Observer<? super T>> E subscribeWith(E observer) {
    subscribe(observer);
    return observer;
}

Par conséquent, subscribeWith peut être utilisé de façon interchangeable avec subscribe.

Pouvez-vous donner un cas d'utilisation de subscribeWith avec exemple? Je suppose que c'
de répondre à la question complètement

La subscribeWith javadoc donne des exemple d'utilisation:

Observable<Integer> source = Observable.range(1, 10);
CompositeDisposable composite = new CompositeDisposable();

ResourceObserver<Integer> rs = new ResourceObserver<>() {
     //...
};

composite.add(source.subscribeWith(rs));

Voir ici l'utilisation de subscribeWith sera de retour que même ResourceObserver objet qui a été instancié. Cela donne la commodité de l'exécution de l'abonnement & ajout de la ResourceObserver à la CompositeDisposable dans une ligne (notez que ResourceObservable implémente Disposable.)

Edit 2 Répondre au second commentaire.

source.subscribeWith(rs); source.abonnez-vous(rs); les deux de retour
SingleObserver exemple,

ObservableSource#subscribe(Observer <? super T> observer) ne PAS retour d'un Observer. C'est une méthode void (Voir la NOTE sous le Observables#abonnez-vous explication ci-dessus). Alors que la Observable#subscribeWith NE retour de la Observer.
Si nous étions à réécrire l'exemple de l'utilisation du code à l'aide ObservableSource#subscribe au lieu de cela, nous aurions du le faire en deux lignes comme suit:

source.subscribe(rs); //ObservableSource#subscribe is a void method so nothing will be returned
composite.add(rs);

Alors que la Observable#subscribeWith méthode fait commode pour nous de faire le ci-dessus en une seule ligne composite.add(source.subscribeWith(rs));

Il peut devenir confus avec tous les surchargé de s'abonner à des méthodes qui ressemblent quelque peu similaires, cependant il y a des différences (dont certains sont subtiles). En regardant le code et la documentation aide à fournir la distinction entre eux.

---

Modifier 3 un Autre exemple de cas d'utilisation pour subscribeWith

La subscribeWith méthode est utile lorsque vous avez un spécifique de la mise en œuvre d'un Observer que vous souhaitez réutiliser. Par exemple, dans l'exemple de code ci-dessus, il a fourni une mise en œuvre spécifique de ResourceObserver dans l'abonnement, héritant ainsi ses fonctionnalités tout en vous permettant de gérer onNext onError et onComplete.

Un autre exemple d'utilisation: pour l'exemple de code dans votre question, que si vous voulez faire le même abonnement pour la get() réponse à plusieurs endroits?

Au lieu de copier la Consumer implémentations pour onNext et onError à travers différentes catégories, ce que vous pouvez faire à la place est de définir une nouvelle classe, par exemple.

//sample code..
public class GetNewsObserver extends DisposableObserver<News> {
    //implement your onNext, onError, onComplete.
    ....
}

Maintenant, chaque fois que vous faites cela get() demande, il vous suffit de vous abonner en faisant:

compositeDisposable.add(get()
    ...
    .subscribeWith(new GetNewsObserver()));

Voir le code est simple maintenant, vous maintenir la séparation de la responsabilité pour le traitement de la réponse, et vous pouvez désormais réutiliser GetNewsObserver où vous le souhaitez.