Как я могу завершить свои тесты на поток Akka?

Я получаю сообщение об ошибке: «Ошибка запуска FlowTests: Название испытания не найден»Как я могу завершить свои тесты на поток Akka?

Я следовал примеры на веб-сайте документации 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] (http://doc.akka.io/api/akka/current/#akka.stream.scaladsl.FileIO$); скорее всего, они дадут вам более правильный и эффективный код. –

Хорошо, я понял. Я использовал класс FlowTest в качестве теста Scala, но мне нужно было создать класс, расширяющий FunSuite, и оттуда вызывать мои FlowTests с awaitAssert()

источник

2016-12-04 18:29:21

Как я могу завершить свои тесты на поток Akka?

ответ

Смежные вопросы