dimanche 4 décembre 2016

How can I complete my tests on Akka flow?

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