не удалось найти неявное значение для параметра sz: org.scalatest.enablers.Size [akka.Done] - PullRequest
Новая
       5

не удалось найти неявное значение для параметра sz: org.scalatest.enablers.Size [akka.Done]

0 голосов
/ 31 января 2019

какой неявный параметр я должен добавить и как?

Я уже пытался добавить: 

  implicit val sz = Size;

Но это не работает. 

    val done = Consumer
    .committableSource(consumerSettings, Subscriptions.topics(topic))
    .map(msg => messageHandler(msg))
    .toMat(Sink.ignore)(Keep.both)
    .mapMaterializedValue(DrainingControl.apply)
    .run()

  Await.result(done.drainAndShutdown(), 5.seconds) should have size 20

Броски: 

errors: Error:(85, 68) could not find implicit value for parameter sz: org.scalatest.enablers.Size 
[akka.Done] Await.result(done.drainAndShutdown(), 5.seconds) should have size 20 

Error:(85, 68) not enough arguments for method size: (implicit sz: org.scalatest.enablers.Size
[akka.Done])org.scalatest.Assertion. Unspecified value parameter sz. Await.result(done.drainAndShutdown(), 5.seconds) should have size 20
...