我正在开发一个应用程序，它有几个长时间运行的流，它订阅关于某个实体的数据并处理这些数据。这些流应该是全天候的，所以我们需要处理故障(网络问题等)。为此，我们将源代码包装在RestartingSource中。我现在正在尝试验证这个行为，虽然它看起来很正常，但我正在努力创建一个测试，在这个测试中，我推送一些数据，验证它是否正确处理，然后发送一个错误，然后验证它是否在此之后重新连接并继续处理。我把它归结为
浏览 11提问于2020-05-18得票数 0
回答已采纳
我正在试验reactive Streams的Test Compatability Kit (tck)，并且我自己测试了几个Publisher，我想测试一个akka Source。但为了做到这一点，我需要将源(或源+处理器)转换为java.util.concurrent.Flow.Publisher。我不知道该怎么做。
有没有一些关于这个问题的文档，或者有人知道答案？
浏览 1提问于2019-07-11得票数 0
我有无限的事件流：即(1448089943, session-1, 10)我编写了一个akka-streams流，它可以很好地处理有限的流，使用groupBy (我的代码基于食谱中的示例)。但是对于无限流，它将无法工作，因
浏览 3提问于2015-11-21得票数 5
回答已采纳
1回答
我是AKKA的新手(我使用的是java)。我不知道如何将zip文件传输到远程参与者。我应该使用akka-http吗？我尝试过akka-streams，但我不能理解如何将二进制文件传输到远程actors。
浏览 1提问于2017-09-19得票数 0
1回答
我很难理解NotUsed和Done在Akka流中的目的和意义。让我们看看以下两个简单的例子：implicit val system = ActorSystem("akka-streams")使用Done
implicit val system = ActorSystem("akka-s
浏览 4提问于2017-10-24得票数 5
回答已采纳
1回答
Java反应式框架的比较
、、、、
我看到许多框架/库声称它们可以帮助在Java语言中构建响应式应用程序，例如: Akka、Vert.x、RxJava、Reactor、QBit等。主要的Java反应式框架之间有什么不同？谢谢您抽时间见我。
浏览 6提问于2015-11-12得票数 35
回答已采纳
1回答
我有一个akka-http路由，它返回一个包含无限实体流的Source。我如何使用路由测试包来测试它？我只想检查流的前n个元素，但我已经查看了测试包代码，看起来似乎没有直接访问响应中的Source的方法。它总是被转换成一个ByteString序列，在我的例子中，这只会导致一个TimeoutException，因为流永远不会终止。作为参考，可以使用如下所示的
浏览 8提问于2017-01-20得票数 1
回答已采纳
我正在寻找akka.stream.scaladsl.Source构造方法，它允许我简单地从不同的代码位置发出下一个值(例如监视系统事件)。
我不太关心背压。目前，我已经使用monix & akka-streams (下面的代码)实现了这一点，
浏览 4提问于2020-03-05得票数 1
回答已采纳
4回答
我有一个flash应用程序，其中包括网格组件，按钮，标签和组合框组件。所有这些组件在应用程序中使用超过70次(同时)。所以它占用了太多的内存。那么，如何测试每个组件在运行时的内存使用情况。是否有任何插件可供浏览器查找内存使用情况。
我使用的是flash CS3和ActionScript 3.0。应用程序应该在浏览器中运行。
浏览 1提问于2010-08-17得票数 1
我正在努力完成EDx platform的EFPL -编程反应式系统课程的最后一个作业(名为反应式追随者)。我尝试过使用mapConcat，但没有成功。我认为现有的流程是：
even
浏览 0提问于2019-07-03得票数 0
1回答
如何为每个selenium测试监控内存使用、数据库访问等。我在groovy中有一个完全使用selenium测试的大型项目。我知道如何使用jprofiler，但它只监控整个内存/cpu使用情况，不提供有关单个测试的任何信息。最后，我希望能够提出一些图表，显示每个测试的内存使用情况，这样我就可以检测到使用大量内存的
浏览 0提问于2011-02-23得票数 0
我已经对400个并发用户运行了JMeter测试，对于下面的GET请求有125个循环计数。
包含代码的蝗虫文件from locust import HttpUser, taskfrom_pt=%s" %(from_point),headers=headers)
我需要找出我做蝗虫测试的错
浏览 3提问于2021-11-02得票数 0
1回答
例如，为了估计部署1000个Drupal实例的成本，我应该调查哪些事情？数据库空间应用程序处理时间(再说一次，如何度量？)DevOps /技术支持时间
这一切都是为了带来一个SaaS平台。我还有什么要考虑的吗？我<
浏览 0提问于2017-04-25得票数 4
我在观察我的网站的内存使用情况。我发送到快递服务器的每一个请求，内存使用量加起来都是0.5MB，使用后不会降低。这是否意味着需要修复内存泄漏？
浏览 6提问于2022-06-18得票数 1
回答已采纳
1回答
我做了一个简单的应用程序，它搜索用户计算机上的文件和文件夹。由于我目前是一年级的学生，没有受过任何正式的培训，在我还在学习C#和.Net框架的时候就已经申请了，所以我不了解专业人员使用的单元测试和其他好的测试方法。尽管我的大部分代码运行良好，但有时会引发异常或发生其他一些意外情况，并且代码会中断。记住上述经验，我认为我的应用程序
浏览 0提问于2014-01-22得票数 -1
回答已采纳
我想要监视windows2003server上的交换空间使用情况。如果10分钟内使用率超过80%，则会产生告警。RAM有很多工具，但是交换使用情况如何呢？如何模拟该条件并进行测试？
浏览 15提问于2010-08-31得票数 0
5回答
我正在做一个项目，我们的单元测试只有13%的代码覆盖率。我想提出一个改善这一点的计划，但首先将重点放在扩大覆盖率将带来最大价值的领域。这个项目是用C#编写的，我们使用VS2008和TFS2008，我们的单元测试是用MSTest编写的。
我应该使用什么方法来确定我们应该首先处理哪些类？我应该查看哪些指标(代码或<
浏览 4提问于2010-03-18得票数 7
回答已采纳
如何将tcp.bind()连接的Sink切换到TCP？例如，假设我有： .toPath(destinationSink.foreach(incomingConnection -> wire(incomingConnection, tmpFileSink)))目前，它将传入的字节保存到<em
浏览 16提问于2021-05-29得票数 0
我想要准确地估计我的android应用程序的功耗。例如，通过网络使用率、GPS使用率等分析电力使用情况。如何对我的应用程序的电池使用情况进行基准测试？
浏览 0提问于2017-11-10得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
