Struct Buffer 

pub struct Buffer { /* private fields */ }

Implementations

impl Buffer

pub fn new() -> Buffer

pub fn add_buffer_size_monitor(&mut self) -> Receiver<BufferSizeMessage>

pub fn set_stdout_size(&mut self, size: usize)

Trait Implementations

impl Connectable for Buffer

fn add_output( &mut self, port: OutputPort, breakable: Breakable, src_id: usize, dst_id: usize, ) -> Result<Pull, ConnectableAddOutputError>

fn add_input( &mut self, pull: Pull, unused_priority: isize, ) -> Result<(), ConnectableAddInputError>

impl StartableControl for Buffer

fn start<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = MotionResult<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,