Struct streamson_lib::handler::buffer::Buffer

pub struct Buffer { /* fields omitted */ }

Buffer handler responsible for storing slitted JSONs into memory

Implementations

impl Buffer

pub fn new() -> Self

Creates a new handler which stores output within itself

pub fn pop(&mut self) -> Option<(String, Bytes)>

Pops the oldest value in the buffer

Returns

• None - queue is empty
• Some((path, data)) - stored data remove from the queue and returned

Example

use streamson_lib::handler;
let mut buffer = handler::buffer::Buffer::new();
while let Some((path, data)) = buffer.pop() {
    // Do something with the data
    println!("{} (len {})", path, data.len());
}

Trait Implementations

impl Debug for Buffer

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Default for Buffer

fn default() -> Buffer

Returns the "default value" for a type.

impl Handler for Buffer

fn handle(&mut self, path: &str, data: &[u8]) -> Result<(), Handler>

Calls handler on splitted data

fn show_path(&self) -> bool

Should path be displayed in the output

fn separator(&self) -> &str

A str which will be used to separate records