IngressAdapter

byteor_adapters

Trait IngressAdapter 

Source 
pub trait IngressAdapter: Adapter {
    // Required method
    fn read_next(
        &mut self,
        out: &mut [u8],
    ) -> Result<Option<usize>, AdapterError>;
}
Expand description

Ingress adapter: produces input messages.

The API is deliberately simple and allocation-free for callers: the caller provides out.

Required Methods§

Source

fn read_next(&mut self, out: &mut [u8]) -> Result<Option<usize>, AdapterError>

Read the next message.

Returns:

  • Ok(Some(n)) when n bytes were written to out
  • Ok(None) on end-of-stream

Implementations on Foreign Types§

Source§

impl<T> IngressAdapter for Box<T>
where T: IngressAdapter + ?Sized,

Source§

fn read_next(&mut self, out: &mut [u8]) -> Result<Option<usize>, AdapterError>

Implementors§