Android RX Java, 无法解析 scheduler.io()

Question

我对 Java、Android 和 RX 非常陌生 Java.I 我有兴趣与 RX Java 一起实现架构组件。

我有一个存储库，它调用我的 API 服务以从服务器获取会话 ID。我在将数据顺利传输到我希望在房间中使用和存储数据的存储库时遇到问题。

改装界面：-

Observable<MainResponse> sendJsonLink1(@Query("svc")String svc, 
@Query("params")String params);

API服务：

MtsApiInterface mtsApiInterface 
=RetrofitInstance.getRetrofitInstance().create(MtsApiInterface.class);

public Observable<MainResponse> GetSessionandResourceID(String svc, String 
params) {
    return mtsApiInterface.sendJsonLink1(svc, params);
}

存储库：

public MutableLiveData<String> getSessionId() {
    Observable<MainResponse> mainResponseObserver = 
mtsAPI.GetSessionandResourceID("token/login", AppConstants.PARAMS + "");
    mainResponseObserver.subscribeOn(Scheduler.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Observer<MainResponse>() {
                @Override
                public void onSubscribe(Disposable d) {

                }

                @Override
                public void onNext(MainResponse mainResponse) {

                }

                @Override
                public void onError(Throwable e) {

                }

                @Override
                public void onComplete() {

                }
            });

    return msessionId;

}

上面的存储库代码不起作用，它说无法解析 scheduler.io()....

我卡在了最后一部分。我不知道如何获取存储库中的数据并将其通过实时数据发送到视图模型。

Answer 1

是Schedulers.io()不是Scheduler.io()

"Scheduler" 与 's'

来自文档

Schedulers.io() - meant for I/O-bound work such as asynchronous performance of blocking I/O, this scheduler is backed by a thread-pool that will grow as needed; for ordinary computational work, switch to Schedulers.computation( ); Schedulers.io( ) by default is a CachedThreadScheduler, which is something like a new thread scheduler with thread caching

Android RX Java, 无法解析 scheduler.io()

Android RX Java, can not resolve scheduler.io()

android

rx-android