Struct ConcurrentProgressStrategy 

pub struct ConcurrentProgressStrategy { /* private fields */ }

Concurrent strategy that provides real-time feedback as targets become ready

Implementations

impl ConcurrentProgressStrategy

pub const fn new(concurrency_limit: usize) -> Self

Creates a new concurrent progress strategy

Trait Implementations

impl AsyncConnectionStrategy for ConcurrentProgressStrategy

fn execute_streaming<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, targets: &'life1 [Target], checker: &'life2 dyn AsyncTargetChecker, config: &'life3 WaitConfig, ) -> Pin<Box<dyn Future<Output = Result<Vec<TargetResult>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Streaming implementation that yields results as they complete

fn execute<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, targets: &'life1 [Target], checker: &'life2 dyn AsyncTargetChecker, config: &'life3 WaitConfig, ) -> Pin<Box<dyn Future<Output = Result<WaitResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Execute the connection strategy for multiple targets

fn name(&self) -> &'static str

Get strategy name

impl Default for ConcurrentProgressStrategy

fn default() -> Self

Returns the “default value” for a type.