Um leere Antwort mit retrofit-und rxjava 2.x

Bei der Verwendung rxjava 1.x ich verwendet, um zurück Observable<Void> zu handhaben leere Antwort von retrofit:

@POST( "login" )
Observable<Void> getToken( @Header( "Authorization" ) String authorization,
                                       @Header( "username" ) String username,
                                       @Header( "password" ) String password );

Aber da rxjava 2.x wird nicht emittieren alles mit Void ist es eine gute Praxis mit den leeren Antworten?

InformationsquelleAutor Samuel Eminet | 2017-01-09
  1. 37

    Ausfüllbaren wurde entwickelt für solche Fälle. Zur Verfügung da RxJava 1.1.1. Von der offiziellen docs:

    Stellt eine latente Berechnung ohne Wert, sondern nur Indiz für den Abschluss oder die Ausnahme. Die Klasse folgt einem ähnlichen Ereignis-Muster als Reaktiv-Streams: onSubscribe (onError|onComplete)?

    So einfach ändern Sie Ihre Methode Rückgabetyp:

    @POST("login")
Completable getToken(@Header("Authorization") String authorization,
                     @Header("username")      String username,
                     @Header("password")      String password);

    Und schreiben Sie Ihre Abonnenten, z.B.:

    apiManager.getToken(auth, name, pass)
    ...
    .subscribe(() -> {
        //success
    }, exception -> {
        //error
    });
    InformationsquelleAutor Maksim Ostrovidov
  2. 6

    Andere Lösung ist:

    @POST("login")
Observable<Response<Void>> getToken( @Header( "Authorization" ) String authorization,
                                       @Header( "username" ) String username,
                                       @Header( "password" ) String password );
    InformationsquelleAutor Leo Droidcoder
  3. -1

    Haben Sie versucht, mit Observable<Object> ?

    Dies ist aus der offiziellen Dokumentation von RxJava 2:

    enum Irrelevant { INSTANCE; }

Observable<Object> source = Observable.create((ObservableEmitter<Object> emitter) -> {
   System.out.println("Side-effect 1");
   emitter.onNext(Irrelevant.INSTANCE);

   System.out.println("Side-effect 2");
   emitter.onNext(Irrelevant.INSTANCE);

   System.out.println("Side-effect 3");
   emitter.onNext(Irrelevant.INSTANCE);
});

source.subscribe(e -> { /* Ignored. */ }, Throwable::printStackTrace);
    InformationsquelleAutor Ionut Negru
Schreibe einen Kommentar