Trait batch_aint_one::Processor

pub trait Processor<K, I, O = (), E = String>
where
    E: Display,
{
    // Required method
    fn process<'life0, 'async_trait>(
        &'life0 self,
        key: K,
        inputs: impl 'async_trait + Iterator<Item = I> + Send
    ) -> Pin<Box<dyn Future<Output = Result<Vec<O>, E>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Process a batch of inputs for a given key.

Required Methods

fn process<'life0, 'async_trait>( &'life0 self, key: K, inputs: impl 'async_trait + Iterator<Item = I> + Send ) -> Pin<Box<dyn Future<Output = Result<Vec<O>, E>> + Send + 'async_trait>>

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

Process the batch.

The order of the outputs in the returned Vec must be the same as the order of the inputs in the given iterator.

Object Safety

This trait is not object safe.

Implementors