Method fill_buffer

examples/pulsar_processor_complex.rs:91–104

(&mut self, buffer_size: usize)

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

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

        Ok((0..buffer_size)
            .into_iter()
            .map(|i| {
                ProcKafkaMessage {
                    key: format!("{}", i).into_bytes(),
                    payload: format!("payload - {}", i),
                    topic: format!("topic1"),
                    partition: 1,
                }
            })
            .collect::<VecDeque<ProcKafkaMessage>>())
    }
}