RxJava1 à Rxjava2 Migration Erreur

Question

Conversion code RxJava1 à RXJava2 Donner cette erreur, ne sais pas ce que je fais mal

aucune instance (s) de la variable de type (s) R existe de telle sorte que seul> est conforme à ObserableSource

API Appel

@GET("/search/users?per_page=2") 
Observable<UsersList> searchGithubUsers(@Query("q") String searchTerm); 

@GET("https://stackoverflow.com/users/{username}") 
Observable<User> getUser(@Path("username") String username); 

RxJAva1:

public Observable<List<User>> searchUsers(final String searchTerm) { 
     return Observable.defer(() -> githubUserRestService.searchGithubUsers(searchTerm).concatMap(
       usersList -> Observable.from(usersList.getItems()) 
         .concatMap(user -> githubUserRestService.getUser(user.getLogin())).toList())) 
       .retryWhen(observable -> observable.flatMap(o -> { 
        if (o instanceof IOException) { 
         return Observable.just(null); 
        } 
        return Observable.error(o); 
       })); 
    } 

RXJava2

public Observable<List<User>> searchUsers(final String searchTerm) { 
     return Observable.defer(() -> githubUserRestService.searchGithubUsers(searchTerm).concatMap(
       usersList -> Observable.fromIterable(usersList.getItems()) 
         .concatMap(user -> githubUserRestService.getUser(user.getLogin())).toList())) 
       .retryWhen(observable -> observable.flatMap(o -> { 
        if (o instanceof IOException) { 
         return Observable.just(null); 
        } 
        return Observable.error(o); 
       })); 
    } 

Answer 1

toList retours Single 2.x; vous devez appliquer toObservable() après. Notez également que Observable.just(null) est interdit: nulls ne sont généralement pas autorisés avec RxJava 2.

Observable<List<User>> searchUsers(final String searchTerm) { 
    return Observable.defer(() -> 
     githubUserRestService 
      .searchGithubUsers(searchTerm) 
      .concatMap(usersList -> 
       Observable.fromIterable(usersList.getItems()) 
        .concatMap(user -> 
         githubUserRestService 
         .getUser(user.getLogin())) 
         .toList() 
         .toObservable() 
        ) 
      ) 
      .retryWhen(observable -> 
       observable.flatMap(o -> { 
        if (o instanceof IOException) { 
         return Observable.just(0); 
        } 
        return Observable.error(o); 
       }) 
      ) 
     ); 
}