2回答
我不知道如何立即停止akka stream Runnable Graph？如何使用killswitch来实现这一点？我创建akka streams才几天。在我的例子中，我从文件中读取行，并在flow中执行一些操作，然后写入接收器。我想要做的是，在我想要的时候立即停止读取文件，我希望这可能会停止整个运行的图形。任何关于这方面的想法都将非常感谢。
浏览 9提问于2016-08-03得票数 5
回答已采纳
1回答
我构建了一个基于alpakka项目的非常简单的akka流，但是它没有从kafka读取任何东西，尽管它连接并创建了一个消费群体。我已经为流创建了隐式Actor系统和Materializer。
浏览 2提问于2019-06-06得票数 1
回答已采纳
1回答
我正在使用Alpakka播放文件中的Akka流和流内容。我需要在一段时间后停止流，所以我想使用KillSwitch，但是我不知道如何使用它，因为我使用的是图形DSL。我的图表是这样的：
浏览 0提问于2017-04-22得票数 3
回答已采纳
import akka.NotUsedimport akka.stream.Add
.named("Ticker")
override def receive: Receiv
浏览 13提问于2019-05-12得票数 3
回答已采纳
我有Akka流，这是从文件读取使用alpakka，处理数据和写入一个文件。我希望在处理n个元素后停止流，计算持续时间和呼叫系统终止时间。我怎样才能做到这一点？我的流量看起来是这样的： import GraphDSL.Implicits._
so
浏览 3提问于2017-04-23得票数 3
回答已采纳
我正在为我的一个已经使用Rx Scala的项目尝试使用Akka流的一些东西。我很想看看Akka流是如何适合取代Rx Scala库的。有一件事，我不可能看到的阿克卡流，是有可能有一个源头和许多沉没。比如说，在这个例子中，直接从Akka Streams文档中提取出来：val sink = Sink.fold[Int, Int]
浏览 4提问于2016-04-26得票数 2
回答已采纳
1回答
我需要创建一个具有以下接口的函数： // Implementation goes here我的问题是，我不知道如何定义流到目前为止，我还没有在Akka文档中找到任何东西。此外
浏览 5提问于2018-01-17得票数 2
我定义了一个简单的图，它结合了一个常量流(通过Source.Single(5000)定义)和一个非常量源(例如Source(1 to 100))。我的图通过ZipLatestWith运算符将这两个数字相加。目的是将流的输出设置为5001, 5002, 5003, 5004, ..., 5100。实际上，程序的输出只是简单的5000，然后流终止，大概是因为Single源代码结束了。
如何获得预期的结果，其中具有常量值5
浏览 20提问于2019-11-21得票数 0
回答已采纳
我有一个非常简单的流来处理一个文件--只是一个FileIO.FromFile源、一个通过流和一个Last接收器："First“状态的文档在接收到一个元素后”取消“，我认为这意味着接收器向流发出取消信号，这将关闭源。但是当这个流运行时，会发生两件事。: Akka.Streams.Actors.Cancel2)文件被锁定，因此任何进一步读取它的
浏览 0提问于2018-05-17得票数 0
我最近开始使用Play 2.5，我想知道这样做的目的是什么：我有几段代码无法工作，多亏了这一点，我解决了这个问题，
浏览 0提问于2016-04-27得票数 21
回答已采纳
我需要移除产品收藏中的文件。( b)石英作业计划作为依赖发挥2.3(活化剂)
( c) Akka异步作业(我不知道如何使用它，如何与play集成，甚至我也是Akka
浏览 0提问于2015-08-24得票数 6
我希望用Flink替换我的基于Akka Streams的流处理器的一部分。目前是否可以使用Akka Streams作为Flink的源，然后在同一代码库中使用Flink作为Akka Streams的源？Flow -> Logger Flow -> Sink
lazy private val converterGraph: Graph[ClosedShape.type, Future[Done]]read
浏览 2提问于2019-04-24得票数 1
1回答
我正在调用一个使用via的方法，如下所示：.take(1).zip(Source.fromIterator错误声明：
[error] found : [as, mat, ec]scala.concurrent.Future[akka.stream.scaladsl.Flow[akka.util.ByteString[akka.stream.scaladsl.Flow[akka</e
浏览 0提问于2018-12-16得票数 0
回答已采纳
1回答
我试图用Akka流实现一个Websocket流。在入口、插座和连接问题上，我会遇到无数令人讨厌的运行时异常。，因为我还没有找到一个可以解释图形、形状、流和深度物化值的单件。编辑1object Login {
def graph(system: ActorSystem, future: Future[LoginCommand.UserData[exasol.LoginComman
浏览 0提问于2018-09-04得票数 1
回答已采纳
2回答
我想添加一些更改，以保留请求和响应之间的关系。我怎么能相信呢？Rest流的物化值是NotUsed。有可能在某种程度上使用Keep.both吗？
浏览 3提问于2017-10-25得票数 1
回答已采纳
我们有以下架构 SQS (源) SQS轮询器->我们的业务逻辑->接收器，它从SQS中删除消息。 这是一个akka流(我们的业务逻辑有多个阶段)。现在，我们希望通过添加HTTP服务器(而不是Akka HTTP)来扩展此体系结构。现在我们的服务也有了一条路径 HTTP服务器->我们的业务逻辑->接收器，它完成了一个未来，表明HTTP响应已经完成。 现在，每当HTTP请求到来时，我都需要一种机制来调用流。现在，SQS源代码本质上是一
浏览 14提问于2019-01-09得票数 0
回答已采纳
我正在尝试创建一个示例akka流，该流接受CSV文件，将其更改为XML (使用已经存在的具有toXml函数的对象)，然后将其发布到端点。我创建的代码如下所示： Http().cachedHostConnectionPool[Thing]("localhost",5000)
val file[(akka.http.scaladsl.model.HttpRequest, com.cogpp.exp.Thin
浏览 1提问于2017-05-18得票数 1
回答已采纳
我在Scala项目中使用Akka Streams API，在Intellij中使用SBT插件。我有一个员工池流，如下所述：。这是我的代码：import akka.stream.scaladsl.{FlowShape, Graph}
def apply[In, Out](
worker: Flow[In, Out, Any],workerCount: I
浏览 2提问于2017-11-18得票数 2
回答已采纳
2回答
我有n源，我想按优先级合并在Akka流中。我的实现基于，其中三个优先级源被合并。我试图用以下方法抽象出Source的数量：import akka.stream.{ClosedShape, Graph, Materializer} at akka.s
浏览 1提问于2018-06-11得票数 0
回答已采纳
1回答
替代Scala中的线程执行器池
、、、、
我的应用程序要求我有多个线程运行，从不同的HDFS节点获取数据。为此，我使用线程执行器池和分叉线程。:
浏览 2提问于2015-01-21得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
