Struct Ingress

pub struct Ingress<'a, D: Digester, Urc: AtatUrc, const RES_BUF_SIZE: usize, const URC_CAPACITY: usize, const URC_SUBSCRIBERS: usize> { /* private fields */ }

Implementations

impl<'a, D: Digester, Urc: AtatUrc, const RES_BUF_SIZE: usize, const URC_CAPACITY: usize, const URC_SUBSCRIBERS: usize> Ingress<'a, D, Urc, RES_BUF_SIZE, URC_CAPACITY, URC_SUBSCRIBERS>

pub fn new( digester: D, buf: &'a mut [u8], res_slot: &'a ResponseSlot<RES_BUF_SIZE>, urc_channel: &'a UrcChannel<Urc, URC_CAPACITY, URC_SUBSCRIBERS>, ) -> Self

Trait Implementations

impl<D: Digester, Urc: AtatUrc, const RES_BUF_SIZE: usize, const URC_CAPACITY: usize, const URC_SUBSCRIBERS: usize> AtatIngress for Ingress<'_, D, Urc, RES_BUF_SIZE, URC_CAPACITY, URC_SUBSCRIBERS>

fn write_buf(&mut self) -> &mut [u8]

Get the write buffer of the ingress

fn try_advance(&mut self, commit: usize) -> Result<(), Error>

Commit a given number of written bytes to the ingress and make them visible to the digester.

async fn advance(&mut self, commit: usize)

Commit a given number of written bytes to the ingress and make them visible to the digester.

fn clear(&mut self)

fn try_write(&mut self, buf: &[u8]) -> Result<usize, Error>

Write a buffer to the ingress and return how many bytes were written.

async fn write(&mut self, buf: &[u8])

Write a buffer to the ingress

async fn read_from<R: Read>(&mut self, serial: R) -> !

Read all bytes from the provided serial and ingest the read bytes into the ingress from where they will be processed