Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。
Akka流代码：Source.range（1，100）.map（i-> {return Stream.of（i * 4）.t oList（）;}）。runWith（Sink.foreach（a-> System.out .println（a）），实现器）；我想创建一个方法，说...
我一直在与Akka actor一起构建应用程序，现在我已经完成了基于actor的业务逻辑，我想为其提供RESTful + websocket前端。我正在尝试找到...
我想使用akka流进行跟踪。。我尝试了广播，也尝试了To，但并没有解决我的问题。Source-> DBSink-> APISink。我首先想在交易时将元素发送到数据库...
我想依次使用Akka Stream。源-> Sink1-> Sink2示例：假设我们有List（1,2,3）作为源Elem 1：将其发送到Sink1，如果接收器1成功，将其发送到接收器2
[从2.5版开始，Play的默认流处理库是Akka Streams。我在任何地方都找不到官方文档，我想知道Play 2.5使用的Akka Stream版本到底是什么？
[我正在尝试使用带有akka-http的scala启动REST API。我是akka和actor模型范例的新手，所以我想实现一个类型化的actor系统，但是我收到了sbt编译错误：找不到...
Java / Kotlin- Akka流Source.reduce如果Source中为null，则不起作用
在Akka Streams Doku中，给出了一个Scala示例，其中包含一个空值的列表。该列表转换为Source，并像示例中那样减少。不幸的是，在Java / Kotlin中，这不是...
在线程“ main”中获取Akka流代码时出错，异常java.lang.NoClassDefFoundError：scala / Function1 $ class
[当我运行akka流代码时，我遇到了以下Java错误：**线程“ main”中的异常java.lang.NoClassDefFoundError：akka.stream.Supervision $$ ...处的scala / Function1 $ class ...
[INFO] [06/01/2020 05：05：53.947] [default-akka.actor.default-dispatcher-6] [SingleSourceLogic（akka：// default）] [7347a]正在启动。 StageActor Actor [akka：// default / system / Materializers / StreamSupervisor-0 / ...
在Play应用中，我创建了一个套接字服务器：程序包控制器import play.api.mvc._ import play.api.libs.streams.ActorFlow import javax.inject.Inject import akka.actor.ActorSystem import akka.stream。 ..
[现在正在使用从我的scala / akka / play应用程序发布的SNS时，获取池正在关闭来自akka的消息
我有一些流大约每分钟醒来，并从数据库中提取一些文档并执行一些操作，最后将消息发送到SNS。滴答间隔当前为每1分钟。 ...
我尝试在Akka流中连接多个流，并根据流以不同的方式处理它们的错误。可以使用诸如此类的东西来实现：Flow [String，Either [ProcessingError，...
akka Actor中的可变集合返回NullPointerException
我有一个演员，每次调用websocket时都会调用websocket并更新地图。演员在命令的另一点使用相同的地图。类...
根据文档[1]，我一直试图在Akka Stream中并行化流，但是由于某些原因，我没有得到预期的结果。我遵循了文档中概述的步骤，...
我有一个Akka Streams流，有一点我需要对代码块使用mapAsync。 （...）.via（flow1）.mapAsync（1）（response => *几行代码her *）.via（...
Scala Akka http发布请求，带有正文和喷雾json
[这是我目前使用的方法之一-val uri =“ https：// blahblah / blah / export” val body = Map（“ search”->“最早搜索= -2040h index = app_events sourcetype = kube ：container：shop | ...
是否有可能从Akka Streams Flow中生成多个元素
假设我有一个字符串“ sky is blue”，并且在内部流程中，我将其分为几个元素，我希望将这些元素向下传播。 Source.single（“仅一个元素”）.via（Flow.fromFunction（...
onSuccess的值不是scala.concurrent.Future [Any]
我想从某个网址发出请求，但无法通过val f：Future [Any] = actor1吗？ SyncRequest（url）f.onSuccess {案例供稿：xml.Elem => ...
我有一个具有Scala Play的HTTP后端。工作良好。现在，我想在其之上设置一个gRPC-API（理论上这应该起作用）。要设置gRPC，我基本上遵循了akka-quickstart，我可以运行sbt ...
为什么akka http可以在不扩展特征的情况下使用方法路径？
通过akka http示例：https：//doc.akka.io/docs/akka-http/current/introduction.html#using-akka-http对象WebServer {val route = path（“ hello”）{get { complete（HttpEntity（...