Struct holochain::prelude::kitsune_p2p::dependencies::kitsune_p2p_types::dependencies::rustls::internal::msgs::deframer::MessageDeframer

pub struct MessageDeframer { /* private fields */ }

This deframer works to reconstruct TLS messages from arbitrary-sized reads, buffering as necessary. The input is read(), get the output from pop().

Implementations

impl MessageDeframer

pub fn new() -> MessageDeframer

pub fn pop(&mut self) -> Result<Option<OpaqueMessage>, Error>

Return any complete messages that the deframer has been able to parse.

Returns an Error if the deframer failed to parse some message contents, Ok(None) if no full message is buffered, and Ok(Some(_)) if a valid message was found.

pub fn read(&mut self, rd: &mut dyn Read) -> Result<usize, Error>

Read some bytes from rd, and add them to our internal buffer.

pub fn has_pending(&self) -> bool

Returns true if we have messages for the caller to process, either whole messages in our output queue or partial messages in our buffer.

Trait Implementations

impl Default for MessageDeframer

fn default() -> MessageDeframer

Returns the “default value” for a type.