Method handle_batch

examples/dynamic_batching.rs:148–169

(&mut self, batch: Vec<Product>)

    async fn drain(&mut self, batch: Vec<Product>);

    async fn handle_batch(&mut self, batch: Vec<Product>) -> Result<(), BatcherTerminate<Input>> {
        
        // we just check first product
        // because we now all others same for current instance
        
        let ct = batch[0].ctype;

        match ct {
            Category::Cars => {
                self.batch_cars_insert(batch);
            }
            Category::Mobiles => {
                self.batch_mobiles_insert(batch);
            }
            Category::Accessories => {
                self.batch_accessories_insert(batch);
            }
        }


        ProcResult::Continue
    } 
}