scala - 如何完成 Akka Flow 测试?

标签 scala testing akka akka-stream

我收到一条错误消息“运行 FlowTests 时出错:找不到测试名称”

我一直在关注 Akka 文档网站上的示例,但它们似乎不起作用

这是我的测试代码:

class FlowTests extends TestKit(ActorSystemContainer.getInstance().getSystem) {

  val usersDataLines = scala.io.Source.fromFile("data/BX-Users-TEST.csv", "ISO-8859-1").getLines().drop(1)
  val usersSource = Source.fromIterator(() => usersDataLines)

  usersSource.runWith(TestSink.probe[String]).expectNext("some data").expectComplete()
}

最佳答案

好吧,我明白了。我使用 FlowTest 类作为 Scala 测试,但是我需要做的是创建一个扩展 FunSuite 的类,然后从那里用 awaitAssert() 调用我的 FlowTests

关于scala - 如何完成 Akka Flow 测试?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40957790/

相关文章:

scala - 位移和符号

java - 如何使用 Spring dbunit 模拟数据库 View ?

cassandra - 如何复制 Akka Persistence Cassandra 数据库

Java Play2-Akka 工作

scala - 如何在 Scala 中复制 Spark 数据框中的元素?

scala - sbt 1.2.8 在非 sudo 模式下抛出错误 (fedora)

json - 如何使用包含 "$"的列名进行查询?

java - Arquillian 测试未执行

ios - 无法使用 delphi firemonkey iOS 应用程序在应用程序购买中进行测试

elasticsearch - 使用Akka Streams,我如何知道源何时完成?