使用RxJava 2和Retrofit 2从可观测对象检索数据

// 创建可观测对象
Observable<Data> observable = Observable.just(data);

// 定义网络请求接口
public interface ApiService {
    @GET("data")
    Observable<Data> getData();
}

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

// 创建网络请求对象
ApiService apiService = retrofit.create(ApiService.class);

// 发起网络请求
Observable<Data> observable = apiService.getData();

// 处理网络请求结果
observable
        .subscribeOn(Schedulers.io()) // 在IO线程进行网络请求
        .observeOn(AndroidSchedulers.mainThread()) // 在主线程处理结果
        .subscribe(new Observer<Data>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 订阅时的操作
            }

            @Override
            public void onNext(Data data) {
                // 处理成功的结果
            }

            @Override
            public void onError(Throwable e) {
                // 处理错误的结果
            }

            @Override
            public void onComplete() {
                // 请求完成的操作
            }
        });