Struct SimpleUpdateProcessor 

pub struct SimpleUpdateProcessor;

Default UpdateProcessor that immediately awaits the coroutine.

This is used when ApplicationBuilder.concurrent_updates is set to an integer – the semaphore in BaseUpdateProcessor provides the actual bounding.

Trait Implementations

impl Debug for SimpleUpdateProcessor

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

Formats the value using the given formatter.

impl Default for SimpleUpdateProcessor

fn default() -> SimpleUpdateProcessor

Returns the “default value” for a type.

impl UpdateProcessor for SimpleUpdateProcessor

fn do_process_update<'life0, 'async_trait>( &'life0 self, _update: Arc<Update>, coroutine: Pin<Box<dyn Future<Output = ()> + Send>>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Custom implementation of how to process an update. Must be implemented by the concrete type.

fn initialize<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called once before the processor starts handling updates.

fn shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called once when the processor is shutting down.