Struct qiniu_objects_manager::BatchOperations

pub struct BatchOperations<'a> { /* private fields */ }

批量操作

Implementations

impl<'a> BatchOperations<'a>

pub fn batch_size(
    &mut self,
    batch_size: impl BatchSizeProvider + 'a
) -> &mut Self

设置最大批量操作数提供者

pub fn add_operation(
    &mut self,
    operation: impl OperationProvider + 'a
) -> &mut Self

添加对象操作提供者

pub fn add_operations<I: IntoIterator<Item = Box<dyn OperationProvider + 'a>> + Send + Sync + 'a>(
    &mut self,
    new_iter: I
) -> &mut Selfwhere
    <I as IntoIterator>::IntoIter: Sync + Send,

批量添加操作提供者

Examples found in repository

src/batch_operations.rs (line 68)

    pub fn add_operation(&mut self, operation: impl OperationProvider + 'a) -> &mut Self {
        let new_iter = vec![Box::new(operation) as Box<dyn OperationProvider + 'a>].into_iter();
        self.add_operations(new_iter)
    }

pub fn before_request_callback(
    &mut self,
    callback: impl FnMut(&mut RequestBuilderParts<'_>) -> AnyResult<()> + Send + Sync + 'a
) -> &mut Self

设置请求前回调函数

pub fn after_response_ok_callback(
    &mut self,
    callback: impl FnMut(&mut ResponseParts) -> AnyResult<()> + Send + Sync + 'a
) -> &mut Self

设置响应成功回调函数

pub fn after_response_error_callback(
    &mut self,
    callback: impl FnMut(&mut ResponseError) -> AnyResult<()> + Send + Sync + 'a
) -> &mut Self

设置响应失败回调函数

pub fn call(&mut self) -> BatchOperationsIterator<'a>

阻塞发起批量操作，返回操作结果迭代器

该方法的的异步版本为 Self::async_call。

pub fn async_call(&mut self) -> BatchOperationsStream<'a>

Available on crate feature async only.

异步发起批量操作，返回操作结果流

Trait Implementations

impl Debug for BatchOperations<'_>

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

Formats the value using the given formatter.