This commit is contained in:
parent
b983f19c1f
commit
0e11ec2057
28 changed files with 674 additions and 120 deletions
|
|
@ -1276,8 +1276,7 @@ private[stream] final class RecoverWith[T, M](maximumRetries: Int, pf: PartialFu
|
|||
if ((maximumRetries == RecoverWith.InfiniteRetries || attempt < maximumRetries) && pf.isDefinedAt(ex)) {
|
||||
switchTo(pf(ex))
|
||||
attempt += 1
|
||||
}
|
||||
else
|
||||
} else
|
||||
failStage(ex)
|
||||
|
||||
def switchTo(source: Graph[SourceShape[T], M]): Unit = {
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue