akka/akka-core

Inconsistent signature of Flow#recoverWithRetries

Aberta

#20.606 aberto em 24 de mai. de 2016

 (3 comentários) (0 reação) (0 responsável)Scala (3.547 forks)batch import
1 - triagedhelp wantedt:stream

Métricas do repositório

Stars
 (13.277 estrelas)
Métricas de merge de PR
 (Mesclagem média 8d 19h) (10 fundiu PRs em 30d)

Description

We discussed this issue at Gitter.

It feels like recovery function should be inside separate argument group, i.e.

recoverWithRetries(42) {
  case _ => Source.empty
}

looks much better than

recoverWithRetries(42, {
  case _ => Source.empty
})

Guia do colaborador