Function relay_utils::process_future_result
source · pub fn process_future_result<TResult, TError, TGoOfflineFuture>(
result: Result<TResult, TError>,
retry_backoff: &mut ExponentialBackoff,
on_success: impl FnOnce(TResult),
go_offline_future: &mut Pin<&mut Fuse<TGoOfflineFuture>>,
go_offline: impl FnOnce(Duration) -> TGoOfflineFuture,
error_pattern: impl FnOnce() -> String,
) -> ProcessFutureResultwhere
TError: Debug + MaybeConnectionError,
TGoOfflineFuture: FutureExt,
Expand description
Process result of the future from a client.