These are chat archives for akkadotnet/AkkaStreams

7th
Sep 2017
Anna Yafi
@annayafi
Sep 07 2017 15:53
hi, does anyone know how to replay a flow in x seconds for x times until giving up on it
var x= Flow.Create<Y, Z>().SelectAsync(1, e => task(e));
x.RecoverWithRetries(...)
I can't give a flow here, it only takes source as a parameter
I need a flow, becasue I need the input parameter to execute it
I see in java or scala they have aRestartSource.withBackoff .
Anna Yafi
@annayafi
Sep 07 2017 16:01
only solution I have here, is in my task, in the thrown exception, passing the parameter and reading it in the exception within the RecoverWithRetries, anyone with a better option ? Thanks