Акка Груп RunForeach

Question

У меня есть источник akka, который я хочу сгруппировать и запустить в пакетном режиме. Я столкнулся с проблемой, и я не совсем уверен, что происходит не так.

У меня есть источник, который выглядит примерно так

val source = Source(facts.toList)
source
  .grouped(config.batchSize)
  .runForeach(batch => {
//Do something
  })

Но я получаю

    [error]  found   : scala.concurrent.Future[akka.Done]
[error]  required: scala.concurrent.Future[Unit]
[error]       .runForeach(batch => {
[error]       

       ^

Почему он не может запустить источник?

Answer 1

Вы не показываете больший контекст, в котором находится ваш фрагмент кода, но я предполагаю, что ваш код является последним выражением внутри метода, который ожидает возвращаемое значение Future[Unit]. Компилятор жалуется, потому что Source#runForeach возвращает Future[Done] вместо Future[Unit].

Быстрое решение проблемы - изменить тип возвращаемого вами метода на Future[Done].