Method drain

examples/pulsar_processor.rs:95–95

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

    async fn terminate(&mut self) {}

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

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