Android/Java 上的 RxJava3:使用 SingleObserver 的问题但 Observer 很好!

问题描述

问题是我可以使用 Observer,但我不能使用 SingleObserver。它给了我这个错误:

Inferred type 'E' for type parameter 'E' is not within its bound; should implement 'io.reactivex.rxjava3.core.Observer<? super com.xxx.Network.Response.ResponseLogin>'

.subscribeWith(new SingleObserver<ResponseLogin>(){
                ^
  required: E
  found: <anonymous SingleObserver<ResponseLogin>>
  reason: inferred type does not conform to upper bound(s)
    inferred: <anonymous SingleObserver<ResponseLogin>>
    upper bound(s): Observer<? super ResponseLogin>
  where E,T are type-variables:
    E extends Observer<? super ResponseLogin> declared in method <E>subscribeWith(E)
    T extends Object declared in class Observable

以下是一些实现细节:

//build.gradle
    implementation "io.reactivex.rxjava3:rxandroid:3.0.0"
    implementation "io.reactivex.rxjava3:rxjava:3.0.2"
//ApiInterface.java
import io.reactivex.rxjava3.core.Observable;
...
public interface ServerAPIInterface {
    // For POST request
    @FormUrlEncoded
    @POST("/login")
    public Observable<ResponseLogin> login(
        // the POST params to server
        @Field("user_email") String user_email,@Field("user_password") String user_password
    );

故障在于:

import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
import io.reactivex.rxjava3.core.Observer;
import io.reactivex.rxjava3.core.SingleObserver;
import io.reactivex.rxjava3.disposables.CompositeDisposable;
import io.reactivex.rxjava3.disposables.Disposable;
import io.reactivex.rxjava3.schedulers.Schedulers;
...
        myApiInterface
                .login(myUserEmail,myPassword)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribeWith(new SingleObserver<ResponseLogin>() {
                    @Override
                    public void onSuccess(ResponseLogin data) {
                        // update the adapter
                    }


                    @Override
                    public void onSubscribe(Disposable d) {
                        disposables.add(d);
                    }

                    @Override
                    public void onError(Throwable e) {
                        // display an error message
                    }
                });

如果我用 SingleObserver 替换 Observer(并实现所有必需的 onXXX() 方法,它编译正常。但我想要一个观察者。

我是否应该降级到 rxjava2(未经测试)?

我怀疑我的导入很混乱。

似乎有 2 个 SingleObserver,另一个在 io.reactivex.SingleObserver

我确实尝试使用这些导入并跳过了其中大部分的 rxjava3 前缀。但是 AndroidSchedulers 只能在 io.reactivex.rxjava3.android.schedulers.AndroidSchedulers 中找到。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)

相关问答

错误1:Request method ‘DELETE‘ not supported 错误还原:...
错误1:启动docker镜像时报错:Error response from daemon:...
错误1:private field ‘xxx‘ is never assigned 按Alt...
报错如下,通过源不能下载,最后警告pip需升级版本 Requirem...