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 set_use_path(self, use_path: bool) -> Self

Set whether to show path

Arguments

• use_path - should path be store with data

Example

use streamson_lib::handler;
let file = handler::Buffer::new().set_use_path(true);

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

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().set_use_path(true);
while let Some((path, data)) = buffer.pop() {
    // Do something with the data
    println!("{} (len {})", path.unwrap(), data.len());
}

pub fn set_max_buffer_size(self, max_size: Option<usize>) -> Self

Sets max buffer size

Arguments

• use_path - should path be store with data

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() -> Self

Returns the “default value” for a type.

impl FromStr for Buffer

type Err = Handler

The associated error which can be returned from parsing.

fn from_str(input: &str) -> Result<Self, Self::Err>

Parses a string s to return a value of this type.

impl Handler for Buffer

fn start(
    &mut self,
    _path: &Path,
    _matcher_idx: usize,
    token: Token
) -> Result<Option<Vec<u8>>, Handler>

Is called when a path is matched

fn feed(
    &mut self,
    data: &[u8],
    _matcher_idx: usize
) -> Result<Option<Vec<u8>>, Handler>

Is called when handler receives some data

fn end(
    &mut self,
    _path: &Path,
    _matcher_idx: usize,
    token: Token
) -> Result<Option<Vec<u8>>, Handler>

Is called when the path is no longer matched

fn as_any(&self) -> &dyn Any

Function to allow downcasting

fn is_converter(&self) -> bool

Should be handler used to convert data