如何实现BehaviorSubject + retrofit api调用

public interface ApiService {
    @GET("api/data")
    Observable<DataResponse> getData();
}

private BehaviorSubject<DataResponse> dataSubject = BehaviorSubject.create();

public Observable<DataResponse> getDataObservable() {
    return dataSubject;
}

public void fetchData() {
    ApiService apiService = RetrofitClient.getInstance().create(ApiService.class);
    apiService.getData()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Observer<DataResponse>() {
                @Override
                public void onSubscribe(Disposable d) {
                    // 可以在这里进行一些初始化操作
                }

                @Override
                public void onNext(DataResponse dataResponse) {
                    // 接收到数据后，将数据发射给BehaviorSubject
                    dataSubject.onNext(dataResponse);
                }

                @Override
                public void onError(Throwable e) {
                    // 处理错误情况
                    dataSubject.onError(e);
                }

                @Override
                public void onComplete() {
                    // 请求完成
                    dataSubject.onComplete();
                }
            });
}

dataManager.getDataObservable()
        .subscribe(new Observer<DataResponse>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 可以在这里进行一些初始化操作
            }

            @Override
            public void onNext(DataResponse dataResponse) {
                // 处理获取到的数据
            }

            @Override
            public void onError(Throwable e) {
                // 处理错误情况
            }

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