Struct EnhancedCollectionIterator 

pub struct EnhancedCollectionIterator<'a, T> { /* private fields */ }

Enhanced collection iterator with rate limiting and progress tracking

Implementations

impl<'a, T> EnhancedCollectionIterator<'a, T>

where T: DeserializeOwned + Clone,

Constructor methods for EnhancedCollectionIterator

pub fn new(client: &'a Client, url: impl Into<String>) -> Self

Create a new enhanced iterator with default configuration

pub fn with_config( client: &'a Client, url: impl Into<String>, config: IteratorConfig, ) -> Self

Create a new enhanced iterator with custom configuration

impl<'a, T> EnhancedCollectionIterator<'a, T>

where T: DeserializeOwned + Clone,

Builder pattern methods for EnhancedCollectionIterator

pub fn with_limit(self, limit: u32) -> Self

Set batch size limit

pub fn with_rate_limiter(self, limiter: Arc<TokenBucketLimiter>) -> Self

Set custom rate limiter

impl<'a, T> EnhancedCollectionIterator<'a, T>

where T: DeserializeOwned + Clone,

Accessor methods for EnhancedCollectionIterator

pub fn total_fetched(&self) -> u64

Get total items fetched so far

pub fn batch_count(&self) -> u32

Get number of batches fetched

Trait Implementations

impl<'a, T> PaginatedIterator<T> for EnhancedCollectionIterator<'a, T>

where T: DeserializeOwned + Clone + Send + Sync,

type Error = Error

fn next_batch<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Vec<T>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Fetch the next batch of items

fn has_more(&self) -> bool

Check if there are more items to fetch

fn hint_remaining(&self) -> Option<usize>

Get an approximation of items remaining if available

fn stats(&self) -> IteratorStats

Get statistics about fetching

fn collect_all<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = Result<Vec<T>, Self::Error>> + Send + 'async_trait>>

where Self: Sized + Send + 'async_trait,

Collect all remaining items