akka-stream 相关问题

如何处理组中的groupby子流

我一直在玩akka-streams，似乎遇到了一个问题，我找不到一个干净的方法来处理这个问题。我有来自1 ... *玩家的活动......

scala akka akka-stream

如何使用基于请求参数的Flows在akka-http中引入非阻塞延迟

我正在启动服务器并使用akka stream connection.handleWith（handleRequest（））处理它，其中handleRequest（）：Flow [HttpRequest，HttpRespnse，_]我需要在发送时创建延迟...

scala akka akka-stream akka-http

在Redis pub / sub和Akka Streams中使用SSE的最简单方法是什么？

我想为以下场景流式传输分块服务器发送事件：订阅Redis密钥，如果密钥更改，则使用Akka Streams流式传输新值。如果有......它应该只流

scala redis akka akka-stream akka-http

如何从cassandra事件流中获取最后一个事件

我正在阅读一个cassandra事件流，并希望得到最后一个元素。我目前正在这样做：def myData：Future [Long] = readJournal（myPersistenceId）。drop（5）.take（1）.map（...

scala akka akka-stream

在“Akka-Streams”中使用`extrapolate`的用例是什么？

我只是尝试在akka-streams中进行混淆和推断。由于混淆对我来说很有意义，我没有得到推断的用例。我们为什么要为下游添加更多工作 - 当......

scala akka akka-stream

复合流程的目的是什么（来自Sink和Source）？

我正在尝试从网站上理解复合流（来自Sink和Source），它们表示如下：有人可以提供复合流的使用示例。 ...

akka akka-stream

协议切换成功与否

我有以下代码片段，不能编译：import akka.actor.ActorSystem import akka.Done import akka.http.scaladsl.Http import akka.stream.ActorMaterializer import akka.stream ....

scala akka akka-stream akka-http

在Consumer API中使用createDrainingControl？

我正在浏览Alpakka中Kafka的Consumer API文档。我遇到了这段代码。根据我的理解，使用msg.committableOffset（）提交偏移量。那为什么......

akka kafka-consumer-api akka-stream alpakka