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

Single.timeout介绍

暂无

代码示例

代码示例来源：origin: Netflix/EVCache

public Single<Map<String, T>> getSome(long to, TimeUnit units, boolean throwException, boolean hasZF, Scheduler scheduler) {
  final Stopwatch operationDuration = EVCacheMetricsFactory.getStatsTimer(appName, serverGroup, metricName).start();
  return observe().timeout(to, units, Single.create(subscriber -> {
    try {
      final Collection<Operation> timedoutOps = new HashSet<Operation>();

代码示例来源：origin: Netflix/EVCache

public Single<T> get(long duration, TimeUnit units, boolean throwException, boolean hasZF, Scheduler scheduler) {
  return observe().timeout(duration, units, Single.create(subscriber -> {
    // whenever timeout occurs, continuous timeout counter will increase by 1.
    MemcachedConnection.opTimedOut(op);
    if (op != null) op.timeOut();
    if (!hasZF) EVCacheMetricsFactory.getCounter(appName, null, serverGroup.getName(), appName + "-get-CheckedOperationTimeout", DataSourceType.COUNTER).increment();
    if (throwException) {
      subscriber.onError(new CheckedOperationTimeoutException("Timed out waiting for operation", op));
    } else {
      if (isCancelled()) {
        if (hasZF) EVCacheMetricsFactory.getCounter(appName, null, serverGroup.getName(), appName + "-get-Cancelled", DataSourceType.COUNTER).increment();
      }
      subscriber.onSuccess(objRef.get());
    }
  }), scheduler).doAfterTerminate(new Action0() {
    @Override
    public void call() {
      
    }
  }
  );
}

代码示例来源：origin: couchbase/couchbase-jvm-core

.timeout(env.socketConnectTimeout() + connectCallbackGracePeriod, TimeUnit.MILLISECONDS)
.onErrorResumeNext(new Func1<Throwable, Single<? extends ChannelFuture>>() {
  @Override

代码示例来源：origin: com.couchbase.client/core-io

.timeout(env.socketConnectTimeout() + connectCallbackGracePeriod, TimeUnit.MILLISECONDS)
.onErrorResumeNext(new Func1<Throwable, Single<? extends ChannelFuture>>() {
  @Override