Rxjava3使用Retrofit,提示Cannot resolve method 'subscribe' in 'Object' about rxlife HOT 7 CLOSED

public class Erweimalogin {
    private int code;
    private String msg;
    public int getCode() {
        return code;
    }
    public void setCode(int code) {
        this.code = code;
    }
    public String getMsg() {
        return msg;
    }
    public void setMsg(String msg) {
        this.msg = msg;
    }
}
public interface Lejia {
    @GET("weixin/login/xcx")
    Observable<Erweimalogin> erweima_login(@Query("token") String token);
}
private boolean isgetuser = false;
 Retrofit retrofit = new Retrofit.Builder()
                    .baseUrl("https://" + G.gStrYuMing + "/") // 设置 网络请求 Url
                    .addConverterFactory(GsonConverterFactory.create()) //设置使用Gson解析(记得加入依赖)
                    .addCallAdapterFactory(RxJava3CallAdapterFactory.create()) // 支持RxJava
                    .build();
            // 创建 网络请求接口 的实例
            Lejia request = retrofit.create(Lejia.class);
            Observable observable = request.erweima_login("test123");
            observable.delay(1, TimeUnit.SECONDS)
                    .repeatUntil(new BooleanSupplier() {
                        @Override
                        public boolean getAsBoolean() throws Exception {
                            return isgetuser;
                        }
                    })
                    .retryWhen(new RetryWithDelay(20,1000))
                    .takeUntil(new Predicate<Erweimalogin>() {
                        @Override
                        public boolean test(Erweimalogin integer) throws Exception {
                            return (integer.getCode() == 1);
                            // 返回true时，就停止发送事件
                        }
                    })
                    .subscribeOn(Schedulers.io())               // 切换到IO线程进行网络请求
                    .observeOn(AndroidSchedulers.mainThread())  // 切换回到主线程 处理请求结果
//                    .to(RxLife.toMain(this))
                    .subscribe(new Observer<Erweimalogin>() {
                        @Override
                        public void onSubscribe(Disposable d) {
                            Log.d(TAG, "dingyue");
                            disposable=d;
                        }
                        @Override
                        public void onNext(Erweimalogin result) {
                            // e.接收服务器返回的数据
                            Log.i(TAG, String.valueOf(result.getMsg()));
                        }
                        @Override
                        public void onError(Throwable e) {
                            // 获取轮询结束信息
                            Log.d(TAG, e.toString());
                        }
                        @Override
                        public void onComplete() {
                            Log.d(TAG, "完成");
                        }
                    });

public class Presenter extends BaseScope {
        private boolean isgetuser = false;
        public Presenter(LifecycleOwner owner) {
            super(owner); //添加生命周期监听
        }
        public void test1() {
            //步骤1:创建Retrofit对象
            Retrofit retrofit = new Retrofit.Builder()
                    .baseUrl("https://" + G.gStrYuMing + "/") // 设置 网络请求 Url
                    .addConverterFactory(GsonConverterFactory.create()) //设置使用Gson解析(记得加入依赖)
                    .addCallAdapterFactory(RxJava3CallAdapterFactory.create()) // 支持RxJava
                    .build();
            // 步骤2:创建 网络请求接口 的实例
            Lejia request = retrofit.create(Lejia.class);
            Observable observable = request.erweima_login("test123");
            // 步骤3：发送网络请求进行轮询
            observable.delay(1, TimeUnit.SECONDS)
                    .repeatUntil(new BooleanSupplier() {
                        @Override
                        public boolean getAsBoolean() throws Exception {
                            return isgetuser;
                        }
                    })
                    .retryWhen(new RetryWithDelay(20,1000))
                    .takeUntil(new Predicate<Erweimalogin>() {
                        @Override
                        public boolean test(Erweimalogin integer) throws Exception {
                            return (integer.getCode() == 1);
                            // 返回true时，就停止发送事件
                        }
                    })
                    .subscribeOn(Schedulers.io())               // 切换到IO线程进行网络请求
                    .observeOn(AndroidSchedulers.mainThread())  // 切换回到主线程 处理请求结果
//                    .to(RxLife.toMain(this))
                    .subscribe(new Observer<Erweimalogin>() {
                        @Override
                        public void onSubscribe(Disposable d) {
                            Log.d(TAG, "dingyue");
                            disposable=d;
                        }
                        @Override
                        public void onNext(Erweimalogin result) {
                            // e.接收服务器返回的数据
                            Log.i(TAG, String.valueOf(result.getMsg()));
                        }
                        @Override
                        public void onError(Throwable e) {
                            // 获取轮询结束信息
                            Log.d(TAG, e.toString());
                        }
                        @Override
                        public void onComplete() {
                            Log.d(TAG, "完成");
                        }
                    });
        }
    }