Method terminate

examples/pulsar_processor_complex.rs:87–87

(&mut self)

    async fn init(&mut self) {}

    async fn terminate(&mut self) {}

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