Struct BaseUpdateProcessor 

pub struct BaseUpdateProcessor { /* private fields */ }

Wraps any UpdateProcessor with a semaphore to bound concurrency.

Implementations

impl BaseUpdateProcessor

pub fn new( inner: Box<dyn UpdateProcessor>, max_concurrent_updates: usize, ) -> Result<Self, UpdateProcessorError>

Creates a new BaseUpdateProcessor.

Errors

Returns UpdateProcessorError::InvalidConcurrency if max_concurrent_updates is zero.

pub fn max_concurrent_updates(&self) -> usize

The maximum number of updates that can be processed concurrently.

pub fn current_concurrent_updates(&self) -> usize

A snapshot of the number of updates currently being processed.

pub async fn process_update( &self, update: Arc<Update>, coroutine: Pin<Box<dyn Future<Output = ()> + Send>>, )

Acquires the semaphore and then delegates to UpdateProcessor::do_process_update.

pub async fn initialize(&self)

Delegates to the inner processor’s initialize.

pub async fn shutdown(&self)

Delegates to the inner processor’s shutdown.

Trait Implementations

impl Debug for BaseUpdateProcessor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.