使用Retrofit进行连续的api调用并返回observable

// 添加依赖
implementation 'com.squareup.retrofit2:retrofit:2.9.0'
implementation 'io.reactivex.rxjava2:rxjava:2.2.21'
implementation 'io.reactivex.rxjava2:rxandroid:2.1.1'

// 创建Retrofit实例
Retrofit retrofit = new Retrofit.Builder()
        .baseUrl("https://api.example.com/")
        .addConverterFactory(GsonConverterFactory.create())
        .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
        .build();

// 创建API接口
interface ApiService {
    @GET("users/{id}")
    Observable<User> getUser(@Path("id") int userId);
}

// 创建Observable对象
ApiService apiService = retrofit.create(ApiService.class);
Observable<User> userObservable = apiService.getUser(1);

// 发起网络请求
userObservable.subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Observer<User>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 可在此处进行一些初始化操作
            }

            @Override
            public void onNext(User user) {
                // 处理请求成功的响应结果
            }

            @Override
            public void onError(Throwable e) {
                // 处理请求失败的情况
            }

            @Override
            public void onComplete() {
                // 请求完成时的回调
            }
        });