如何完成Akka流测试？

我得到一个错误，指出“错误运行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() 
}

来源

2016-12-04 Titus Juocepis

我认为你需要使用一些测试框架，如ScalaTest进行测试可以运行，但我不是100％确定的。此外，而不是'scala.io.Source'考虑使用本地方法从[FileIO]的磁盘I/O（http://doc.akka.io/api/akka/current/#akka.stream.scaladsl.FileIO$ ）;最有可能的是，他们会给你更正确和高性能的代码。 –

好吧我想通了。我使用FlowTest类作为Scala测试，但是我需要做的是创建一个扩展FunSuite的类，并从那里调用我的FlowTests与awaitAssert（）

来源

2016-12-04 18:29:21

如何完成Akka流测试？

回答

相关问题