Struct RateLimited 

pub struct RateLimited<R> { /* private fields */ }

Implementations

impl<R> RateLimited<R>

pub fn new(inner: R, requests_per_minute: u32) -> Self

Trait Implementations

impl<Input, Output, R> Runnable<Input, Output> for RateLimited<R>

where Input: Send + Clone + 'static, Output: Send + 'static, R: Runnable<Input, Output> + Send + Sync,

fn invoke<'life0, 'async_trait>( &'life0 self, input: Input, ) -> Pin<Box<dyn Future<Output = Result<Output, WesichainError>> + Send + 'async_trait>>

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

fn stream<'a>( &'a self, input: Input, ) -> BoxStream<'a, Result<StreamEvent, WesichainError>>

fn batch<'life0, 'async_trait>( &'life0 self, inputs: Vec<Input>, ) -> Pin<Box<dyn Future<Output = Vec<Result<Output, WesichainError>>> + Send + 'async_trait>>

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

fn abatch<'life0, 'async_trait>( &'life0 self, inputs: Vec<Input>, ) -> Pin<Box<dyn Future<Output = Vec<Result<Output, WesichainError>>> + Send + 'async_trait>>

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

fn to_serializable(&self) -> Option<SerializableRunnable>