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

Single.fromCallable介绍

暂无

代码示例

代码示例来源：origin: io.requery/requery

@Override
public <E extends T> Single<E> update(final E entity, final Attribute<?, ?>... attributes) {
  return Single.fromCallable(new Callable<E>() {
    @Override
    public E call() {
      return delegate.update(entity, attributes);
    }
  });
}

代码示例来源：origin: io.requery/requery

@Override
public <E extends T> Single<Iterable<E>> upsert(final Iterable<E> entities) {
  return Single.fromCallable(new Callable<Iterable<E>>() {
    @Override
    public Iterable<E> call() {
      return delegate.upsert(entities);
    }
  });
}

代码示例来源：origin: io.requery/requery

@Override
public <E extends T, K> Single<E> findByKey(final Class<E> type, final K key) {
  return Single.fromCallable(new Callable<E>() {
    @Override
    public E call() {
      return delegate.findByKey(type, key);
    }
  });
}

代码示例来源：origin: io.requery/requery

@Override
public <E extends T> Single<E> upsert(final E entity) {
  return Single.fromCallable(new Callable<E>() {
    @Override
    public E call() {
      return delegate.upsert(entity);
    }
  });
}

代码示例来源：origin: io.requery/requery

@Override
public <E extends T> Single<E> refresh(final E entity) {
  return Single.fromCallable(new Callable<E>() {
    @Override
    public E call() {
      return delegate.refresh(entity);
    }
  });
}

代码示例来源：origin: io.requery/requery

@Override
public <E extends T> Single<E> refresh(final E entity, final Attribute<?, ?>... attributes) {
  return Single.fromCallable(new Callable<E>() {
    @Override
    public E call() {
      return delegate.refresh(entity, attributes);
    }
  });
}

代码示例来源：origin: io.requery/requery

@Override
public <E extends T> Single<Iterable<E>> refresh(final Iterable<E> entities,
                         final Attribute<?, ?>... attributes) {
  return Single.fromCallable(new Callable<Iterable<E>>() {
    @Override
    public Iterable<E> call() {
      return delegate.refresh(entities, attributes);
    }
  });
}

代码示例来源：origin: io.requery/requery

@Override
public <E extends T> Single<Void> delete(final Iterable<E> entities) {
  return Single.fromCallable(new Callable<Void>() {
    @Override
    public Void call() {
      delegate.delete(entities);
      return null;
    }
  });
}

代码示例来源：origin: io.requery/requery

@Override
public <E extends T> Single<E> update(final E entity) {
  return Single.fromCallable(new Callable<E>() {
    @Override
    public E call() {
      return delegate.update(entity);
    }
  });
}

代码示例来源：origin: io.requery/requery

@Override
public <E extends T> Single<Iterable<E>> update(final Iterable<E> entities) {
  return Single.fromCallable(new Callable<Iterable<E>>() {
    @Override
    public Iterable<E> call() {
      return delegate.update(entities);
    }
  });
}

代码示例来源：origin: io.requery/requery

@Override
public <E extends T> Single<Void> delete(final E entity) {
  return Single.fromCallable(new Callable<Void>() {
    @Override
    public Void call() {
      delegate.delete(entity);
      return null;
    }
  });
}

代码示例来源：origin: io.requery/requery

@Override
public <R> Single<R> runInTransaction(final Function<BlockingEntityStore<T>, R> function) {
  return Single.fromCallable(new Callable<R>() {
    @Override
    public R call() throws Exception {
      return function.apply(toBlocking());
    }
  });
}

代码示例来源：origin: io.requery/requery

@Override
public <E extends T> Single<Iterable<E>> insert(final Iterable<E> entities) {
  return Single.fromCallable(new Callable<Iterable<E>>() {
    @Override
    public Iterable<E> call() {
      return delegate.insert(entities);
    }
  });
}

代码示例来源：origin: io.requery/requery

@Override
public <K, E extends T> Single<Iterable<K>> insert(final Iterable<E> entities,
                          final Class<K> keyClass) {
  return Single.fromCallable(new Callable<Iterable<K>>() {
    @Override
    public Iterable<K> call() {
      return delegate.insert(entities, keyClass);
    }
  });
}

代码示例来源：origin: io.requery/requery

@Override
public <E extends T> Single<E> refreshAll(final E entity) {
  return Single.fromCallable(new Callable<E>() {
    @Override
    public E call() {
      return delegate.refreshAll(entity);
    }
  });
}

代码示例来源：origin: io.requery/requery

/**
   * Converts this Scalar computation to a single {@link rx.Single}.
   *
   * @return {@link rx.Single} for the result of this query.
   */
  @CheckReturnValue
  public rx.Single<E> toSingle() {
    return Single.fromCallable(this);
  }
}

代码示例来源：origin: groupon/FeatureAdapter

public Single<Deal> getDeal() {
 return Single
  .fromCallable(this::createDeal)
  .delay(1, TimeUnit.SECONDS);
}

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

Single<String> content(int id) {
  return Single.fromCallable(() -> jdbcTemplate
      .queryForObject(
          "SELECT content FROM articles WHERE id = ?",
          String.class, id))
      .subscribeOn(Schedulers.io());
}

代码示例来源：origin: Petikoch/Java_MVVM_with_Swing_and_RxJava_Examples

public Single<FinishedIndicator> createAccount(NameFirstname nameFirstname) {
  return Single.fromCallable(() -> {
    try {
      SysOutUtils.sysout("Processing: " + nameFirstname.toString());
      Thread.sleep(5000);    // = Simulation of a "very slow" backend
      SysOutUtils.sysout("Finished: " + nameFirstname.toString());
    } catch (InterruptedException e) {
      SysOutUtils.sysout("Interrupted (=cancelled) -> good!");
    }
    return FinishedIndicator.INSTANCE;
  }).subscribeOn(Schedulers.io());
}

代码示例来源：origin: ubiratansoares/rxassertions

@Test public void single_CompletesWithExpectedValue() {
  Single<String> single = Single.fromCallable(() -> "RxJava");
  RxAssertions.assertThat(single).completes().expectedSingleValue("RxJava");
}