如何使用RxJava和Android订阅执行任务

Question

我只是把我的脚趾头浸入RxJava中，所以请温柔点：）到今天为止，我对异步任务还可以，但它变得越来越复杂，我想我终于偶然发现了一个需求，实际上我很难用简单的异步任务来满足这个需求。这是我的用例：

1）我有一个方法（我们称之为checkNetwork())，它需要在会话中运行一次。如果以前运行过，它会返回缓存的响应。否则，它会执行一个网络html" target="_blank">调用，然后根据结果执行另一个。这两个网络任务都使用OkHttp运行，并且是同步的。方法本身是从AsyncTask运行的。例如：

public class MyApis{

  private boolean mCachedResult;
  private boolean mNetworkChecked;

  ....

  public boolean checkNetwork() {
    if (mNetworkChecked) {
      return mCachedResult;
    }
    doFirstCall();
    // check response, set flags and potentially return
    doSecondCall();
    // check response, set flags, i.e.

    mCachedResult = response.blah
    mNetworkChecked = true;
  }

  public boolean isNetworkChecked(){
    return mNetworkChecked;
}

2）我的代码有多个部分将运行IsNetworkChecked()，如果不运行，则调用CheckNetwork()。在网络条件较差的情况下，CheckNetwork()可能会得到很好的时间，而IsNetworkChecked()将返回false。这将生成相当多的异步任务并将其排入队列。是的，这些任务将很快解决，但我遇到了执行器上默认队列大小的问题。

据我所知，RxJava可以帮助我做到这一点。我想要做的是只运行checkNetwork()一次，如果它已经在运行，那么就不对AsyncTasks进行排队，只需订阅，等待它完成并根据响应执行我的代码（即我的示例中的McachedResult)。

Answer 1

您可以在RxJava 1.0.15中使用fromcallable和replay(1):

Observable<Blah> blahs = Observable.fromCallable(() -> {
    doFirstCall();
    doSecondCall();
    return response.blah;
})
.subscribeOn(Schedulers.io())
.replay(1).autoConnect(0);

blahs.observeOn(AndroidSchedulers.mainThread())
.subscribe(...)