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

Source.runFold介绍

暂无

代码示例

代码示例来源：origin: com.typesafe.play/play_2.11

/**
 * Consumes the data.
 *
 * This method should be used carefully, since if the source represents an ephemeral stream, then the entity may
 * not be usable after this method is invoked.
 * @param mat    the application's materializer.
 * @return a CompletionStage holding the data
 */
public CompletionStage<ByteString> consumeData(Materializer mat) {
  return dataStream().runFold(ByteString.empty(), ByteString::concat, mat);
}

代码示例来源：origin: com.typesafe.play/play_2.12

/**
 * Consumes the data.
 *
 * This method should be used carefully, since if the source represents an ephemeral stream, then the entity may
 * not be usable after this method is invoked.
 * @param mat    the application's materializer.
 * @return a CompletionStage holding the data
 */
public CompletionStage<ByteString> consumeData(Materializer mat) {
  return dataStream().runFold(ByteString.empty(), ByteString::concat, mat);
}

代码示例来源：origin: com.typesafe.play/play

/**
 * Consumes the data.
 *
 * This method should be used carefully, since if the source represents an ephemeral stream, then the entity may
 * not be usable after this method is invoked.
 * @param mat    the application's materializer.
 * @return a CompletionStage holding the data
 */
public CompletionStage<ByteString> consumeData(Materializer mat) {
  return dataStream().runFold(ByteString.empty(), ByteString::concat, mat);
}

代码示例来源：origin: com.typesafe.play/play-ahc-ws-standalone

ByteString blockingToByteString(Source<ByteString, ?> bodyAsSource) {
  try {
    return bodyAsSource
        .runFold(ByteString.createBuilder(), ByteStringBuilder::append, materializer)
        .thenApply(ByteStringBuilder::result)
        .toCompletableFuture()
        .get();
  } catch (InterruptedException | ExecutionException e) {
    throw new RuntimeException(e);
  }
}

代码示例来源：origin: com.typesafe.play/play-ahc-ws-standalone_2.12

ByteString blockingToByteString(Source<ByteString, ?> bodyAsSource) {
  try {
    return bodyAsSource
        .runFold(ByteString.createBuilder(), ByteStringBuilder::append, materializer)
        .thenApply(ByteStringBuilder::result)
        .toCompletableFuture()
        .get();
  } catch (InterruptedException | ExecutionException e) {
    throw new RuntimeException(e);
  }
}