Function fluvio_future::retry::retry

source ·
pub fn retry<I, O, F, E, A>(
    retries: I,
    factory: A
) -> impl Future<Output = Result<O, E>>
where I: IntoIterator<Item = Duration>, A: FnMut() -> F, F: Future<Output = Result<O, E>>, E: Debug,
Expand description

Provides Future with specified retries strategy. See retry_if for details.