RxJava Observer不兼容类型

Question

我正在尝试使用reverfit和RxJava在我正在使用的应用程序中的自定义视图中进行API调用，但是当我尝试订阅来自我的reverfit API调用的Observable时，遇到了一个不兼容类型错误。

我的改装界面：

public interface ApiQueryInterface{
// Request method and URL specified in the annotation
// Callback for the parsed response is the last parameter

@GET("users/")
Observable<Users> getUsers (
        @Query("key") String key,
        @Query("address") String address
);

@GET("posts/")
Observable<Posts> getPosts (
        @Query("key") String key,
        @Query("address") String address
);

}

和位于自定义视图的onFinishInflate（）中的改装调用：

        // Create RxJava adapter for synchronous call
    RxJava2CallAdapterFactory rxAdapter = RxJava2CallAdapterFactory.create();

    // Create Retrofit2 instance for API call
    Retrofit retrofit = new Retrofit.Builder()
            .baseUrl(BASE_URL)
            .addConverterFactory(GsonConverterFactory.create())
            .addCallAdapterFactory(rxAdapter)
            .build();

    // Make API call using retrofit
    final ApiQueryInterface apiQueryInterface = retrofit.create(ApiQueryInterface.class);

    // API return type defined by interface
    Observable<Users> query = apiQueryInterface
            .getUsers(KEY, ADDRESS)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Observer<Users>() {
                @Override
                public void onSubscribe(Disposable d) {

                }

                @Override
                public void onNext(Users users) {

                }

                @Override
                public void onError(Throwable e) {

                }

                @Override
                public void onComplete() {

                }
            });
}

当我构建项目时,在自定义视图中以可观察的 query=...开头的行中遇到了不兼容类型错误：

错误：（60,27）错误：不兼容类型：void无法转换为可观察的

Answer 1

RXJava 1返回一个subscription对象，而不是observable。rxjava 2订阅返回void。这就是为什么您会得到error:(60,27)error:incompatible types。您将在回调onsubscribe中获得可丢弃的。如果需要对它的引用，则可以在调用回调时将其分配给类级成员