RxJava - Combiner deux observables

Question

J'ai besoin de fusionner des images d'une autre demande Retrofit à sa série spécifique. Ce qui semble être une tâche facile m'a plongé dans l'enfer réactif sans aucun signe d'espoir.

Spécifiquement, je crée également le Service via un Observable puisque j'ai besoin d'obtenir un jeton d'authentification pour créer le service. J'ai basé mes essais sur cette réponse: https://stackoverflow.com/a/28418503/2192545.

public void loadSeries(String searchFor) { 

    mainView.showLoadingIndicator(); 
    if (subscription != null) subscription.unsubscribe(); 


    TVApplication application = TVApplication .get(mainView.getContext()); 

    application.getTVService() 
      .flatMap(service -> service.searchSeries(searchFor) 
        .flatMap(series -> Arrays.asList(series).stream() 
          .<List<Series>>flatMap(aSeries -> { 
           Observable<Series> obsSeries = Observable.just(aSeries); 
           Observable<ImageListWrapper> obsImages = service.queryImages(aSeries.getId(), "poster"); 
           return Observable.zip(obsSeries, obsImages, (Series s, ImageListWrapper i) -> combineSeriesData(s, i)); 
          }))); 
} 

private Series combineSeriesData(Series s, ImageListWrapper i) { 
    s.setPosters(i.getImages()); 
    return s; 
} 

Je suis au-dessus de ma tête. Je viens d'obtenir « Impossible déduire le type d'interface fonctionnelle » de la part de Func2 Observable.zip dans l'IDE, le journal de construction dit:

Error:(63, 58) error: incompatible types: bad return type in lambda 

expression 
no instance(s) of type variable(s) T1,T2,R exist so that Observable<R> conforms to Stream<? extends List<Series>> 
where T1,T2,R are type-variables: 
T1 extends Object declared in method <T1,T2,R>zip(Observable<? extends T1>,Observable<? extends T2>,Func2<? super T1,? super T2,? extends R>) 
T2 extends Object declared in method <T1,T2,R>zip(Observable<? extends T1>,Observable<? extends T2>,Func2<? super T1,? super T2,? extends R>) 
R extends Object declared in method <T1,T2,R>zip(Observable<? extends T1>,Observable<? extends T2>,Func2<? super T1,? super T2,? extends R>) 

Answer 1

Ok, commençons par le commencement; ne créez pas le service en tant qu'observable, cela rendra votre code plus difficile. Il y a des façons de contourner cela.

Deuxièmement, vous n'avez pas besoin d'utiliser zip:

application 
    .getTVService() 
    .flatMap(service -> 
    service 
    .searchSeries(searchFor) 
    .flatMapIterable(series -> series) 
    .flatMap(aSeries -> 
     service 
     .queryImages(aSeries.getId(), "poster") 
     .map(i -> combineSeriesData(aSeries, i)) 
    ) 
);