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

Source.mapAsync介绍

暂无

代码示例

代码示例来源：origin: lagom/lagom-recipes

@Override
 public ServiceCall<Source<String, NotUsed>, Source<String, NotUsed>> autonomousStream() {
  return hellos -> completedFuture(
    hellos.mapAsync(8, name -> repository.getMessage(name).thenApply( message ->
      String.format("%s, %s!", message.orElse("Hello"), name)
    ))
  );
 }
}

代码示例来源：origin: lagom/lagom-recipes

@Override
public ServiceCall<Source<String, NotUsed>, Source<String, NotUsed>> directStream() {
 return hellos -> completedFuture(
  hellos.mapAsync(8, name ->  helloService.hello(name).invoke()));
}

代码示例来源：origin: eclipse/ditto

.flatMapConcat(this::mapEntity)
.concat(Source.single(DOES_NOT_HAVE_NEXT_MSG))
.mapAsync(1, msgToForward -> {
  if (DOES_NOT_HAVE_NEXT_MSG.equals(msgToForward)) {
    self.tell(msgToForward, self);

代码示例来源：origin: org.eclipse.ditto/ditto-services-utils-akka

.flatMapConcat(this::mapEntity)
.concat(Source.single(DOES_NOT_HAVE_NEXT_MSG))
.mapAsync(1, msgToForward -> {
  if (DOES_NOT_HAVE_NEXT_MSG.equals(msgToForward)) {
    self.tell(msgToForward, self);