Method fill_buffer

examples/pulsar_processor.rs:97–107

(&mut self, buffer_size: usize)

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

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

        Ok((0..buffer_size)
            .into_iter()
            .map(|i| {
                TestData {
                    data: format!("Pulsar !!"),
                }
            })
            .collect::<VecDeque<TestData>>())
    }
}