我收到一条错误消息“运行 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/