Method drain

examples/dynamic_batching.rs:83–83

(&mut self, _buffer: VecDeque<Product>)

    async fn terminate(&mut self) {}

    async fn drain(&mut self, _buffer: VecDeque<Product>) {}


    async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<Product>, Terminate> {