Struct pea2pea::ConnectionReader

pub struct ConnectionReader {
    pub node: Arc<Node>,
    pub addr: SocketAddr,
    pub buffer: Box<[u8]>,
    pub carry: usize,
    pub reader: OwnedReadHalf,
}

An object dedicated to performing reads from a connection's stream.

Fields

node: Arc<Node>

A reference to the owning node.

addr: SocketAddr

The address of the connection.

buffer: Box<[u8]>

A buffer dedicated to reading from the stream.

carry: usize

The number of bytes from an incomplete read carried over in the buffer.

reader: OwnedReadHalf

The read half of the stream.

Implementations

impl ConnectionReader

pub async fn read_queued_bytes(&mut self) -> Result<&[u8]>

Reads as many bytes as there are queued to be read from the stream.

pub async fn read_exact(&mut self, num: usize) -> Result<&[u8]>

Reads the specified number of bytes from the stream.