Retrofit2 + RxJava2 + RxAndroid错误

当试图创建和订阅Subscriber时，我收到以下错误消息。Retrofit2 + RxJava2 + RxAndroid错误

can not resolve method 'subscribe(anonymous rx.Subscriber<GooglePlacesResponse>)'

的build.gradle

// JSON Parsing 
compile 'com.google.code.gson:gson:2.6.1' 
compile 'com.squareup.retrofit2:retrofit:2.1.0' 
compile 'com.squareup.retrofit2:converter-gson:2.1.0' 
compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0' 
compile 'io.reactivex.rxjava2:rxjava:2.0.2' 
compile 'io.reactivex.rxjava2:rxandroid:2.0.1

GooglePlaceService.java

public interface GooglePlaceService { 

    public static final String GOOGLE_API_KEY = "google_api_key"; 

    @GET("maps/api/place/nearbysearch/json?radius=2000&key="+GOOGLE_API_KEY) 
    Observable<GooglePlacesResponse> getNearbyPlaces(@Query("location") String location); 
}

ApiUtils.java

public class ApiUtils {  

    public static final String GOOGLE_PLACE_BASE_URL = "https://maps.googleapis.com/"; 

    public static GooglePlaceService getGooglePlaceService() { 
     return getClient(GOOGLE_PLACE_BASE_URL).create(GooglePlaceService.class); 
    } 

    public static Retrofit getClient(String baseUrl) { 

     Retrofit retrofit = new Retrofit.Builder() 
       .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) 
       .addConverterFactory(GsonConverterFactory.create()) 
       .baseUrl(baseUrl) 
       .build(); 

     return retrofit; 
    } 
}

Observable Observable<GooglePlacesResponse>如下所示。

Observable<GooglePlacesResponse> mGooglePlacesResponseObervable = ApiUtils.getGooglePlaceService().getNearbyPlaces(latitude + "," + longitude); 

mGooglePlacesResponseObervable 
    .subscribeOn(Schedulers.io()) 
    .observeOn(AndroidSchedulers.mainThread()) 
    .subscribe(new Subscriber<GooglePlacesResponse>() { <-- Error here : can not resolve method `subscribe(anonymous rx.Subscriber<GooglePlacesResponse>)` 

      @Override 
      public void onNext(GooglePlacesResponse googlePlacesResponse) { 

       } 

      @Override 
      public void onCompleted() { 

      } 

      @Override 
      public void onError(Throwable e) { 

      } 
    });

来源

2016-12-24 Priyank Patel

RxJavaCallAdapter

返回RxJava 1 Observable。对于RxJava2，您应该使用RxJava2CallAdapter。看起来这还不是正式的改造版本，但是在2.1.1快照中。您可以自己编译适配器，也可以从Sonatype快照回购中取消依赖关系。

以下内容添加到您的repositories节在build.gradle -

repositories { 
    // Other repos... 
    maven { 
     url = "https://oss.sonatype.org/content/repositories/snapshots/" 
    } 
}

更新您的改装依赖于2.1.1-SNAPSHOT版本。请注意，我们也改变adapter-rxjava到adapter-rxjava2 -

compile 'com.squareup.retrofit2:retrofit:2.1.1-SNAPSHOT' 
compile 'com.squareup.retrofit2:converter-gson:2.1.1-SNAPSHOT' 
compile 'com.squareup.retrofit2:adapter-rxjava2:2.1.1-SNAPSHOT'

和更新改造建设者使用RxJava2CallAdapterFactory -

Retrofit retrofit = new Retrofit.Builder() 
      .addCallAdapterFactory(RxJava2CallAdapterFactory.create()) 
      .addConverterFactory(GsonConverterFactory.create()) 
      .baseUrl(baseUrl) 
      .build();

当2.1.1发布，你可以回去到正规的依赖。

来源

2016-12-24 22:58:48 iagreen

该适配器具有版本2.*.*并不意味着它是为了用于RxJava 2事实

你应该使用官方的适配器为秒版本RxJava的：

compile 'com.squareup.retrofit2:adapter-rxjava2:2.3.0 // works with RxJava 2

然后您可以添加工厂：

Retrofit retrofit = new Retrofit.Builder() 
    .baseUrl("https://api.example.com") 
    .addCallAdapterFactory(RxJava2CallAdapterFactory.create()) 
    .build();

这是full answer。

来源

2017-01-20 08:15:00 Gaket

如果您不想更新改造版本。 Here是一个非常好的库，可以将其从RxJava1.x转换为RxJava2.x对象。首先，添加此
compile "com.github.akarnokd:rxjava2-interop:0.10.2"
到build.gradle和使用方法
RxJavaInterop.toV2Observable(observableRx1)
转换为Rx2的观测量。

来源

2017-08-04 21:34:02

这是我的构建。gradle设置，也许这会帮助其他人

depencies{ 
compile 'com.squareup.retrofit2:retrofit:2.3.0' 
compile 'com.squareup.retrofit2:converter-gson:2.1.0' 
compile 'com.squareup.retrofit2:adapter-rxjava2:2.3.0' 
compile 'io.reactivex.rxjava2:rxandroid:2.0.1' 
compile 'com.squareup.okhttp3:okhttp:3.8.0' 
compile 'com.squareup.okhttp3:logging-interceptor:3.8.0'}

来源

2017-09-20 08:50:33 llb

Retrofit2 + RxJava2 + RxAndroid错误

回答

相关问题