本文整理了Java中scala.concurrent.Future.flatMap()
方法的一些代码示例,展示了Future.flatMap()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Future.flatMap()
方法的具体详情如下:
包路径:scala.concurrent.Future
类名称:Future
方法名:flatMap
暂无
代码示例来源:origin: traneio/future
@Benchmark
public String flatMapConstN() throws Exception {
Future<String> f = constFuture;
for (int i = 0; i < N.n; i++)
f = f.flatMap(flatMapF, ec);
return Await.result(f, inf);
}
代码示例来源:origin: traneio/future
@Benchmark
public String flatMapConst() throws Exception {
return Await.result(constFuture.flatMap(flatMapF, ec), inf);
}
代码示例来源:origin: traneio/future
private Future<Integer> loop(int i) {
if (i > 0)
return Future.successful(i - 1).flatMap(this::loop, ec);
else
return Future.successful(0);
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.10
.flatMap(new Mapper<KvStateLocation, Future<byte[]>>() {
@Override
public Future<byte[]> apply(KvStateLocation lookup) {
代码示例来源:origin: dataArtisans/yahoo-streaming-benchmark
Future<Object> result = actorRefFuture.flatMap(new Mapper<ActorRef, Future<Object>>() {
public Future<Object> apply(ActorRef actorRef) {
LOG.debug("Ask response actor for state for key {}.", queryState.getKey());
代码示例来源:origin: traneio/future
@Benchmark
public String flatMapPromiseN() throws Exception {
Promise<String> p = Promise.<String>apply();
Future<String> f = p.future();
for (int i = 0; i < N.n; i++)
f = f.flatMap(flatMapF, ec);
p.success(string);
return Await.result(f, inf);
}
代码示例来源:origin: traneio/future
@Benchmark
public String flatMapPromise() throws Exception {
Promise<String> p = Promise.<String>apply();
Future<String> f = p.future().flatMap(flatMapF, ec);
p.success(string);
return Await.result(f, inf);
}
代码示例来源:origin: org.apache.flink/flink-runtime-web_2.10
.flatMap(new Mapper<ActorRef, Future<Tuple2<ActorGateway, Object>>>() {
@Override
public Future<Tuple2<ActorGateway, Object>> apply(ActorRef jobManagerRef) {
代码示例来源:origin: org.apache.flink/flink-runtime_2.10
.flatMap(new Mapper<ActorGateway, Future<Object>>() {
@Override
public Future<Object> apply(ActorGateway jobManager) {
代码示例来源:origin: org.apache.flink/flink-runtime_2.10
scala.concurrent.Future<R> flatMappedFuture = scalaFuture.flatMap(new Mapper<T, scala.concurrent.Future<R>>() {
@Override
public scala.concurrent.Future<R> apply(T value) {
内容来源于网络,如有侵权,请联系作者删除!