用于处理JVM上的流数据的Akka实现
我正在尝试在akka流中的Keep组合下创建以下示例：import java.nio.file.Paths import akka.NotUsed import akka.actor.ActorSystem import akka.stream。{...
我正在尝试编写一些代码作为更大集成测试的一部分。我有一个函数创建一个Source类型的KinesisSource [KinesisRecord，Future [Done]：protected def createKinesisSource（...
我无法理解如何使用光滑的配置文件。我的问题：我试图通过Alpakka JDBC插件使用Slick和Akka-stream。在线提供的示例如下：#Load using ...
Alpakka UDP：如何通过已绑定的套接字响应收到的数据报？
我正在使用Alpakkas UDP.bindFlow将传入的UDP数据报转发给Kafka代理。发送这些数据报的遗留应用程序需要来自同一端口的UDP响应消息...
如何将Scala Maps与akka-kryo-serializer一起使用
我正在尝试使用库akka-kryo-serializer。我设法使用字符串作为测试，但是当我使用相同的代码处理Map时，请仔细按照网站的说明进行操作...
从Lagom / Akka Kafka为Websocket主题订阅者创建源代码
我希望我的仅限Lagom订阅者服务订阅Kafka主题并将消息流式传输到websocket。我使用此文档定义了如下服务（https：//www.lagomframework ....
我有一个graphdsl，由于某种原因，在执行webSocketClientFlow的Flow后，我得到一个空流。运行期间的错误消息是：java.util.NoSuchElementException：空头...
我正在尝试使用Akka Flow实现Websocket登录流程。我在Inlet，Outlets和Connection问题上遇到了无数令人讨厌的运行时异常。我的最新消息是：java.lang.IllegalStateException：...
下拉akka-streams和akka-http-streams时添加的正确解析器是什么？我在“http://repo.akka.io/snapshots/”添加了解析器+ =“Akka Snapshot Repository”，但Intellij仍然不能......
Akka文件上传 - 在收到请求结束前发送2xx'早期'响应
我知道这个问题已在这里提出，但我没有找到任何解决问题的方法。始终保持警告：在请求结束前发送2xx'早期'响应...
最近我开始使用Akka，我用它来创建一个使用Akka HTTP上传文件的REST API。该文件可以有数百万条记录，对于每条记录，我需要执行一些验证并...
我已经有了Source [T]，但我需要将它传递给需要Stream [T]的函数。我可以.run源并将所有内容实现到列表然后对结果执行.toStream但是......
我来自ReactiveX，我们有运营商推迟，以便创建一个Observable并在我们有订户后获得排放值。在Akka Streams，我想知道是否......
任何重用Source [ByteString，Any]的方法（不将其保留在内存中）
有没有办法使Source可重用？我有一个接收大文件上传的akka -http服务器，然后通过HTTP将（分块）数据流式传输到用户的websockets和其他HTTP服务器......
根据定义，http响应分为3个部分，status-code - > headers - > body，当执行akka客户端http请求时，在前2个部分之后收到http响应...
与Akka Http Spray Json一起使用SprayJsonSupport时，类路径中缺少“term akka.stream”
我在我的项目中使用akka-http和reactivemongo以及使用akka-http-spray-json编组/解组案例类。这是他们的依赖 - “com.typesafe.akka”%%“akka-http”％“10.1.3”“......
如何使用Akka流Flow.batch批量从源发出的多个元素
我使用以下代码来测试akka流Flow.batch的行为，但我无法弄清楚为什么结果不是我所期望的：Source（1到20）.map（x => {println（s ” ...
我正在尝试使用PlayWS将文件和一些数据发布到Mailgun，但我收到此错误：无法编写akka.stream.scaladsl.Source的实例[play.api.mvc.MultipartFormData.Part [akka.stream。 ...
我正在阅读Akka流的文档，我遇到了mapConcat运算符，就像flatMap一样（至少在概念层面）。这是一个简单的例子：scala> val ...
我有一个List [String]和一个Source.queue。我想在一段时间后提供这个队列字符串元素。像这样：val数据：List [String] =“”val tick = Source.tick（0 ...