82e2e2c551
* RestartWithBackOff delay cancel to wait for failure For wrapping a user flow with FlowRestart.onFlowWithFailures when the user flow it fails signals a cancel upstream and a failure downstream. These are intercepted by a SubSource/SubSink. In the case the SubSource receives the cancel before the SubSink receives the real upstream is wrongly canceled leading to an error when the SubSink restarts the flow. This commit introduces a delay for the cancel so that the failure is more likely to win. Would be far better to propagate a reason for cancel so this could be deterministic. See https://github.com/akka/akka/pull/23909 Refs #24528 #24726 |
||
|---|---|---|
| .. | ||
| src/test | ||