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

Flow.prepend介绍

暂无

代码示例

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

/**
 * Produces a flow of ByteString with a prepended block and a script wrapper.
 *
 * @param callbackName the javascript callback method.
 * @return a flow of ByteString elements.
 */
public static Flow<ByteString, ByteString, NotUsed> flow(String callbackName) {
  ByteString cb = ByteString.fromString(callbackName);
  return Flow.of(ByteString.class).map((msg) -> {
    return formatted(cb, msg);
  }).prepend(Source.single(initialChunk));
}

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

/**
 * Produces a flow of ByteString with a prepended block and a script wrapper.
 *
 * @param callbackName the javascript callback method.
 * @return a flow of ByteString elements.
 */
public static Flow<ByteString, ByteString, NotUsed> flow(String callbackName) {
  ByteString cb = ByteString.fromString(callbackName);
  return Flow.of(ByteString.class).map((msg) -> {
    return formatted(cb, msg);
  }).prepend(Source.single(initialChunk));
}

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

/**
 * Produces a flow of ByteString with a prepended block and a script wrapper.
 *
 * @param callbackName the javascript callback method.
 * @return a flow of ByteString elements.
 */
public static Flow<ByteString, ByteString, NotUsed> flow(String callbackName) {
  ByteString cb = ByteString.fromString(callbackName);
  return Flow.of(ByteString.class).map((msg) -> {
    return formatted(cb, msg);
  }).prepend(Source.single(initialChunk));
}