scala - 如何完成 Akka Flow 测试？

Question

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

Answer 1

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