我正在为 Project Reactor 文档苦苦挣扎。我在 Akka Streams 方面有一些经验，但现在我正在开发一个使用 Projec

我使用来自私有 api 的数据，所以当我多次发出 http 请求时，uri 中的 id 字段有一些变化；在响应中，其

我有一个 akka 流，它向端点发出 get http 请求，并在 minikube 环境中的 kubernetes 上运行，因此在执行过程中

我遇到了一个问题，我被要求使用 akka 流来设计一个搜索 API，以便在几个相关的 .tsv 文件中查找数据。

在以下代码中，<code>tick</code> 每三秒发出一个新对象。我正在尝试使用 <code>groupedWithin</code> （忽略空组

我正在学习 Java Akka 流并使用 <a href="https://doc.akka.io/docs/akka/current/stream/stream-flows-and-basics.html" rel="nofollow

启动了 2 个线程。 <code>dataListUpdateThread</code> 将数字 2 添加到 <code>List</code>。 <code>processFlowThread</code> 对

我正在尝试将 ArrayList 发送到 Akka 流进行处理。流处理列表如下： <pre><code>1. Sum the list 2. Square the resul

我试图返回流操作的结果，在这种情况下是： <ol> <li>总结一个列表</li> <li>平方值</li> <li>平方值</li> <

我们使用 Akka Stream Kafka 来生产和消费消息和 Strimzi Kafka 集群。 如果重要，以下是版本： <pre><code>com.t

我正在尝试在 intellij ide 的 sbt-shell 中为此运行测试命令 -> [https://github.com/theiterators/akka-http-microservice#akka

<code>Source.queue</code> 最近添加了一个 <a href="https://doc.akka.io/docs/akka/current/stream/operators/Source/queue.html#descrip

以下代码在主类的 INIT 方法中 <pre><code>system.scheduler() .scheduleAtFixedRate(Duration.ZERO, Duration.ofMinutes(settings

我是 Akka Streams 和 gRPC 的新手，我正在尝试构建一个端点，客户端发送单个请求，服务器发送多个响应。

我尝试了解 Akka Streams 的 .log 行为，如果它用于促进异步边界的 .async 操作的流中。为了重现这个问题，

我有一个 <code>Source[T, ActorRef[T]]</code>，它是根据 <a href="https://doc.akka.io/docs/akka/current/stream/operators/ActorSour

使用 Akka-http 和流以及 actor，我可以从服务器向客户端发送消息，也可以从客户端接收消息，但是一旦收

我们有一个火花流微批处理过程，它使用来自 kafka 主题的数据，有 20 个分区。分区中的数据是独立的，

我的 akka 流管道中的一个步骤是在接收到无效输入时抛出异常的转换。我想丢弃这些有问题的输入。所

我正在尝试构建一个 Akka Stream <strong>Source</strong>，它通过调用 <code>Future</code> API 来接收数据（<em>API 的