如何完成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流測試？

回答

相關問題