本文整理了Java中rx.Single.observeOn()方法的一些代码示例，展示了Single.observeOn()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Single.observeOn()方法的具体详情如下：
包路径：rx.Single
类名称：Single
方法名：observeOn

Single.observeOn介绍

暂无

代码示例

代码示例来源：origin: filippella/Dagger-Rx-Database-MVP

protected <T> void subscribe(Observable<T> observable, Observer<T> observer) {
    observable.subscribeOn(Schedulers.newThread())
        .toSingle()
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(observer);
  }
}

代码示例来源：origin: meltwater/rxrabbit

@Override
public Single<Void> call(Exchange exchange, RoutingKey routingKey, AMQP.BasicProperties basicProperties, Payload payload) {
  return Single.<Void>create(subscriber -> schedulePublish(exchange, routingKey, basicProperties, payload, 1, 0, subscriber))
      .observeOn(observeOnScheduler);
}

代码示例来源：origin: plusCubed/anticipate

private void updateList() {
  mProgressBar.setVisibility(View.VISIBLE);
  DbUtil.getPerAppListApps(this)
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe(new SingleSubscriber<List<AppInfo>>() {
        @Override
        public void onSuccess(List<AppInfo> newList) {
          mFilterList = newList;
          mProgressBar.setVisibility(View.GONE);
          //TODO: Calling this while the view hasn't been laid out causes jank
          mAdapter.notifyDataSetChanged();
          invalidateEmpty();
        }
        @Override
        public void onError(Throwable error) {
        }
      });
}

代码示例来源：origin: Sinarahimi/MovieInfo

public LiveData<List<Movie>> getMovies() {
    Single<Response<SearchResult>> resultObservable = movieApi.getMovieList();
    resultObservable.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(searchResult -> {
      if (!searchResult.isSuccessful()) {
        Log.i("Repository", "not respond");
      } else {
        movieDatabaseHelper.save(searchResult.body().getSearch());
      }
    }, throwable -> Log.i("Repository", throwable.getMessage()));

    return movieDatabaseHelper.getAll();
  }
}

代码示例来源：origin: Sinarahimi/MovieInfo

public static <T> void request(Single<Response<T>> single, ApiListener<T> listener) {
  single.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe((Response<T> tResponse) -> {
    if (tResponse.isSuccessful()) {
      listener.onSuccess(tResponse.body());
    } else {
      listener.onServerError(tResponse.errorBody().toString());
    }
  }, listener::onError);
}

代码示例来源：origin: jakehilborn/speedr

private void fetchOverpassLimit(final Double lat, final Double lon) {
  if (overpassSubscription != null) return; //Active request to Overpass has not responded yet
  String data = "[out:json];way(around:" +
      RADIUS + "," + lat + "," + lon +
      ")[\"highway\"][\"maxspeed\"];out;";
  overpassSubscription = overpassService.getLimit(data)
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe(new SingleSubscriber<OverpassResponse>() {
        @Override
        public void onSuccess(OverpassResponse overpassResponse) {
          overpassSubscription = null;
          overpassManager.handleResponse(overpassResponse, lat, lon);
        }
        @Override
        public void onError(Throwable error) {
          overpassSubscription = null;
          //Error was already logged in OverpassInterceptor
        }
      });
}

代码示例来源：origin: hitherejoe/AndroidTvBoilerplate

public void getCats(List<Cat> cats) {
  checkViewAttached();
  mSubscription = mDataManager.getCats(cats)
      .observeOn(AndroidSchedulers.mainThread())
      .subscribeOn(Schedulers.io())
      .subscribe(new SingleSubscriber<List<Cat>>() {
        @Override
        public void onSuccess(List<Cat> cats) {
          getMvpView().showCats(cats);
        }
        @Override
        public void onError(Throwable error) {
          getMvpView().showCatsError();
          Timber.e(error, "There was an error loading the cats!");
        }
      });
}

代码示例来源：origin: hitherejoe/AndroidTvBoilerplate

public void searchCats(List<Cat> cats) {
  checkViewAttached();
  mSubscription = mDataManager.getCats(cats)
      .observeOn(AndroidSchedulers.mainThread())
      .subscribeOn(Schedulers.io())
      .subscribe(new SingleSubscriber<List<Cat>>() {
        @Override
        public void onSuccess(List<Cat> cats) {
          getMvpView().showCats(cats);
        }
        @Override
        public void onError(Throwable error) {
          getMvpView().showCatsError();
          Timber.e(error, "There was an error loading the cats!");
        }
      });
}

代码示例来源：origin: plusCubed/anticipate

}).observeOn(AndroidSchedulers.mainThread())
    .subscribe(new SingleSubscriber<List<AppInfo>>() {
      @Override

代码示例来源：origin: akarnokd/akarnokd-misc

@Test
  public void test() throws Exception {
    Single.fromCallable(() -> 42)
    .subscribeOn(Schedulers.io())
    .observeOn(Schedulers.computation())
    .doOnSubscribe(() -> System.out.println("subscribed"))
    .doOnUnsubscribe(() -> System.out.println("unsubscribed"))
    .subscribe(integer -> System.out.println("got result"));

    Thread.sleep(1000);
  }
}

代码示例来源：origin: jakehilborn/speedr

.observeOn(AndroidSchedulers.mainThread())
.subscribe(new SingleSubscriber<HereMapsResponse>() {
  @Override

代码示例来源：origin: nurkiewicz/rxjava-book-examples

@Test
public void sample_6() throws Exception {
  Single<String> single = Single.just("Hello, world!");
  single.subscribe(System.out::println);
  Single<Instant> error =
      Single.error(new RuntimeException("Opps!"));
  error
      .observeOn(Schedulers.io())
      .subscribe(
          System.out::println,
          Throwable::printStackTrace
      );
}

代码示例来源：origin: com.cookingfox/lapasse-rx

single.observeOn(observeOnScheduler);