Trait qiniu_sdk::prelude::ConcurrencyProvider

pub trait ConcurrencyProvider: DynClone + Debug + Sync + Send {
    fn concurrency(&self) -> Concurrency;
    fn feedback(&self, feedback: ConcurrencyProviderFeedback<'_>);
}

并发数获取接口

获取分片上传时的并发数

Required Methods

fn concurrency(&self) -> Concurrency

获取并发数

fn feedback(&self, feedback: ConcurrencyProviderFeedback<'_>)

反馈并发数结果

Implementations on Foreign Types

impl<'a, T> ConcurrencyProvider for &'a mut Twhere
    T: 'a + ConcurrencyProvider + ?Sized,
    &'a mut T: DynClone + Debug + Sync + Send,

fn concurrency(&self) -> Concurrency

fn feedback(&self, feedback: ConcurrencyProviderFeedback<'_>)

impl<T> ConcurrencyProvider for Rc<T>where
    T: ConcurrencyProvider + ?Sized,
    Rc<T>: DynClone + Debug + Sync + Send,

fn concurrency(&self) -> Concurrency

fn feedback(&self, feedback: ConcurrencyProviderFeedback<'_>)

impl<T> ConcurrencyProvider for Box<T, Global>where
    T: ConcurrencyProvider + ?Sized,
    Box<T, Global>: DynClone + Debug + Sync + Send,

fn concurrency(&self) -> Concurrency

fn feedback(&self, feedback: ConcurrencyProviderFeedback<'_>)

impl<T> ConcurrencyProvider for Arc<T>where
    T: ConcurrencyProvider + ?Sized,
    Arc<T>: DynClone + Debug + Sync + Send,

fn concurrency(&self) -> Concurrency

fn feedback(&self, feedback: ConcurrencyProviderFeedback<'_>)

impl<'a, T> ConcurrencyProvider for &'a Twhere
    T: 'a + ConcurrencyProvider + ?Sized,
    &'a T: DynClone + Debug + Sync + Send,

fn concurrency(&self) -> Concurrency

fn feedback(&self, feedback: ConcurrencyProviderFeedback<'_>)

Implementors

impl ConcurrencyProvider for FixedConcurrencyProvider