Struct AsyncOptimizer

pub struct AsyncOptimizer { /* private fields */ }

Async operation optimizer with timeouts and retries

Implementations

impl AsyncOptimizer

pub fn new(max_concurrent: usize, default_timeout: Duration) -> Self

Create new async optimizer

pub async fn execute<F, T>(&self, future: F) -> Result<T, AsyncError>

where F: Future<Output = Result<T, AsyncError>>,

Execute future with optimization

pub async fn execute_with_timeout<F, T>( &self, future: F, timeout_duration: Duration, ) -> Result<T, AsyncError>

where F: Future<Output = Result<T, AsyncError>>,

Execute future with custom timeout

pub async fn execute_with_retry<F, Fut, T>( &self, operation: F, ) -> Result<T, AsyncError>

where F: FnMut() -> Fut, Fut: Future<Output = Result<T, AsyncError>>,

Execute with retry logic

pub async fn batch_execute<F, T>( &self, operations: Vec<F>, ) -> Vec<Result<T, AsyncError>>

where F: Future<Output = Result<T, AsyncError>>,

Batch execute multiple operations