1回答
我有一个包装类AwsS3Bucket，当它被调用时，会返回一个源Source[ByteString, NotUsed]。在我的单元测试用例中，我模拟了这个客户端并做了必要的断言。string")).toIterator)
when(awsS3Bucket.getSource(any[String])).thenReturn(source) 但是，现在我想测试错误场景，在该场景中，any[String])).thenReturn(error) 但是它给了我一个编译问题，我说 Cannot reso
浏览 23提问于2020-03-30得票数 2
回答已采纳
1回答
我在用可重新启动的源和接收器处理akka流中的错误。object Main extends App { } }) restartableSource.runWith(restartableSink)
浏览 8提问于2022-01-10得票数 1
回答已采纳
1回答
channelActorSink
}[INFO] [11/10/2017 17:42:20.431] [akka-streams-akka.actor.defaul
浏览 4提问于2017-11-11得票数 0
回答已采纳
我希望用Flink替换我的基于Akka Streams的流处理器的一部分。目前是否可以使用Akka Streams作为Flink的源，然后在同一代码库中使用Flink作为Akka Streams的源？Akka Streams的当前流量如下：
// Kafka Source -> Read Flow i
浏览 2提问于2019-04-24得票数 1
我是第一次接触卡夫卡的世界。我们计划设置Kafka来满足我们的数据流需求。在我们的例子中，接收器是REST端点。支持Kafka => REST端点连接的连接器有哪些？这类似于AWS简单队列或主题的工作方式。
浏览 1提问于2017-06-09得票数 0
1回答
我已经看到了使用Akka Streams来避免背压的例子，但是我想知道如果我需要在下游获得自定义的acks，这是如何工作的？在我的特定情况下，链中有几个处理消息的flows，当消息到达某个flow时，我想将一个ack传递回源，以便发出信号，表明我现在已经“取得了”正在处理的资源的所有权。这在Akka Streams中是如何工作的？
浏览 0提问于2017-04-03得票数 1
1回答
我是AKKA的新手(我使用的是java)。我不知道如何将zip文件传输到远程参与者。我应该使用akka-http吗？我尝试过akka-streams，但我不能理解如何将二进制文件传输到远程actors。
浏览 1提问于2017-09-19得票数 0
如何在argo和kubernetes中运行akka streams应用程序，我找到了关于kubernetes和akka集群的文档，但我不需要akka集群，我只需要运行一个具有许多参与者的短暂akka应用程序；还是akka集群是必要的？
浏览 29提问于2021-02-12得票数 0
回答已采纳
我使用的是Playframework和Scala。我正在尝试从Kafka消费数据，处理数据，然后通过websockets将数据推送到客户端。不幸的是，我仍然是这项技术的新手。import play.api.libs.json.JsValueimport play.api.libs.streams._
浏览 4提问于2016-05-19得票数 3
在akka.net streams中创建队列源后，如何向队列中添加项？created object中没有Enqueue、Add或Offer方法。
浏览 17提问于2019-05-14得票数 1
1回答
scala中的Akka streams提供了流概念。Java中的等价物是什么？但在Java语言中，Source.take(n)返回的是源，而不是流
浏览 10提问于2020-02-09得票数 0
我是Akka.NET的新手，我正在构建某种websockets，我想使用Akka.NET来处理(转换和转发)传入的流量，使用它的参与者系统。但我想知道怎样才是最好的办法。我有以下问题：
我是否应该在Actor之外创建主侦听器，并为每个传入的“侦听”客户端实例化一个参与者？或者我应该把我的主要听众也放在一个演员里面？或者我应该把我的客户放在演员之外，并把它放在Akka.NET消息中？
浏览 1提问于2017-10-10得票数 2
回答已采纳
使用Akka-Http和Akka-Streams版本2.4，我如何构造一个流，以便它有一个接收器，即一个websocket。例如，我希望有一个源生成随机数，这些数字被过滤，假设保持偶数，然后流到WebSocket作为接收器。
谢谢
浏览 0提问于2016-02-06得票数 1
回答已采纳
3回答
我有生成未绑定源并使用它的示例代码： def main(args : Array[String]): Unit = {
.onComplete{ _ => system.shutdown() }}
浏览 39提问于2015-03-16得票数 25
回答已采纳
2回答
我的阿克卡流继续学习。我想将我的akka应用程序与集成。class ChatClient(name: String) extends Actor { case ChatClient.Message(from, text) =&
浏览 6提问于2016-02-03得票数 4
回答已采纳
我正在试验reactive Streams的Test Compatability Kit (tck)，并且我自己测试了几个Publisher，我想测试一个akka Source。但为了做到这一点，我需要将源(或源+处理器)转换为java.util.concurrent.Flow.Publisher。createFlowPublisher(long elements) {
return new FlowPublisher((int) elements); // <-- h
浏览 1提问于2019-07-11得票数 0
我正在阅读Akka streams的文档，我遇到了mapConcat操作符，它类似于flatMap (至少在概念层面上)。下面是一个简单的例子：src: akka.stream.scaladsl.Source[scala.collection.immutable.Range.Inclusive,akka.NotUsed] = Source(SourceSh
浏览 1提问于2018-01-04得票数 4
回答已采纳
在处理各种背压场景时，我实现了这样一种情况:一个订阅者使用缓冲区的速度很慢，而另一个订阅者则消耗掉扔给它的任何东西。使用Scala和Akka Streams。如果愿意，您可以查看代码以及运行它的测试。
我通常尝试开发一个RxJava版本来进行比较，但我在这个版本上卡住了。在Akka Streams中，我可以构建一个图，其中一个源在2个通道上广播，并从这些通道消耗一个慢接收器和一个快速接收器。每个通道可以独立地应用缓冲和节流。在RxJa
浏览 1提问于2016-09-02得票数 2
我正在尝试akka streams，但在我的简单示例中，我无法获得工作的反压力。无可否认，我没有使用akka (streams)的经验，所以我可能错过了一些重要的东西。我生产(在队列中提供)整数的速度比消费它们的速度更快，所以我认为反压力会发挥作用。我的目标是始终使用放入队列的最新项(这就是为什么我在源队列上使用bufferSize =1和Ove
浏览 0提问于2017-05-28得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
