RxJava1到Rxjava2迁移错误

Question

转换RxJava1代码RXJava2给予这个错误，不知道我做错了

无类型变量（一个或多个）R的实例（S）存在，使得单>符合ObserableSource

API调用

@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回报Single在2.X;之后你必须申请toObservable()。还要注意的是Observable.just(null)禁止：空一般不允许与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); 
       }) 
      ) 
     ); 
}