如何完成 Akka Flow 测试？

Question

我收到一条错误消息 "Error running FlowTests: Test name not found"

我一直在关注 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 class 作为 Scala 测试，但是我需要做的是创建一个扩展 FunSuite 的 class 并从那里用 awaitAssert()

调用我的 FlowTests

如何完成 Akka Flow 测试？

How can I complete my tests on Akka flow?

testing

scala

akka

akka-stream