I am getting an error that says "Error running FlowTests: Test name not found"
I have been following the examples on Akka's documentation website, but they don't seem to work
Here is my code for the test:
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()
}
Aucun commentaire:
Enregistrer un commentaire