回答情况：
提问时间：
问题标签：
我正在尝试弄清楚如何使用akka-stream执行以下有状态操作：
假设我通过流发出一组元素e，其中包含任意一组元素a。如果任何akka-stream专家能在这里提供帮助，那就太棒了。
浏览 1修改于2019-09-06得票数 0
我目前有一个由Akka和Cassandra支持的事件源服务。这是一个名为AuctionService的竞价系统，在某种程度上，我需要检索最后一个名为BiddenOnLot的竞价事件。为此，我使用akka-persistence-query。 // obtain read journal by plugin id "cassandra-qu
浏览 3提问于2017-05-05得票数 0
我需要遍历一个形状像树的API。例如，目录结构或讨论的线索。可以通过以下流程对其进行建模：type Data = String// 1 => [10, 19]// ...// _ =&g
浏览 42修改于2018-08-03得票数 24
回答已采纳
我正在寻找一个“聚合器”块在akka-streams。例如，一个块等待直到它接收到3个字符串，然后触发一个操作-比如计算平均长度-并向下传播该操作的结果。"hallo""cat"4
浏览 2提问于2017-01-09得票数 0
回答已采纳
我过去常常在绑定中设置我的演员系统，如下所示： implicit val Mat: Materializer = ActorMaterializer(ActorMaterializerSettings.create(System).withSupervisionStrategy(Decider)) @deprecated(
"Us
浏览 1提问于2020-11-17得票数 0
回答已采纳
我目前正在构建一个从mongoDb到elasticsearch的数据流解决方案。我的目标是跟踪所有成功传输到elasticsearch的项目。我正在使用akka-streams和elastic4s。目前，进入es的流如下所示 batchSize = batchSize, error
浏览 21修改于2016-07-26得票数 0
我正在努力完成EDx platform的EFPL -编程反应式系统课程的最后一个作业(名为反应式追随者)。在我看来，我应该以某种方式从现有的流程创建一个新的源代码，在阅读了一些内容后，我仍然没有意识到如何执行流程来为新的源代码生成元素。我认为现有的流程是：.via(followersFlow)现有Flow的类型和我试探性的do实现outgoingFlow可以在这里看到：
val
浏览 0提问于2019-07-03得票数 0
全, 我正在开发一个应用程序，它使用alpakka spring boot集成来从kafka读取数据。我已经准备好了大部分代码，唯一的问题是如何初始化一个连续运行的流，因为这将是一个后端应用程序，并且不会有任何api可供调用？
浏览 26提问于2021-09-01得票数 0
回答已采纳
我想有一个复杂的Flow，我可以在2个不同的Shapes之间切换，这取决于流入图形的数据。当我们返回一个ClosedShape时，这个图是静态的，但是当我们返回FlowShape时，我想知道是否有可能在它内部创建某种动态流。我看着this question，似乎他们使用了一个Partition，我不知道如何应用它，或者它是否真的解决了我的问题。 我从这个例子开始，我被代码中的注释卡住了。 import akka.actor.ActorSystemimport akka.stream.scaladsl.{Flow, GraphDSL,
浏览 26提问于2020-12-03得票数 0
回答已采纳
并不是说我的应用程序是一个纯粹的akka-stream应用程序，我也不会显式地创建actor，而是让akka-stream来做。我需要一些专门的调度器为我的流的某个特定阶段。
浏览 14提问于2019-10-26得票数 0
回答已采纳
现在，我想把func变成一个Flow[A, B]，以便在akka-stream中使用它们。
浏览 16提问于2019-03-21得票数 0
回答已采纳
= Seq( "com.typesafe.akka" %% "akka-streamakkaHttpVersion, "com.typesafe.akka" %% "akka
浏览 21修改于2020-11-16得票数 1
1回答
这似乎令人难以置信，但我找不到akka-stream源代码库。主github包含一个，但它不包含当前的发布源。
目前，我设法通过-source.jar发行版：访问代码。
浏览 3修改于2016-01-01得票数 1
libraryDependencies += { "com.typesafe.akka" %% "akka-stream
浏览 8提问于2018-09-08得票数 0
回答已采纳
1回答
我正在使用akka-stream来解析文件。在我的文件中，我有标题行在第一位，没有其他地方。如何在我的流中先跳过这个头文件？我不想每次都检查行是否为表头。有没有办法做到这一点？
浏览 9提问于2019-05-03得票数 0
我正在使用Alpakka和Slick模块创建一个akka-stream，但我遇到了类型不匹配的问题。
浏览 47提问于2021-10-22得票数 0
回答已采纳
下面是它们的依赖关系："com.typesafe.akka" %% "akka-stream" % "2.5.14^我还收到了关于reactivemongo和akka-stream
浏览 6修改于2018-08-30得票数 2
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号