Struct ChannelBuffer 

pub struct ChannelBuffer<C: Channel> { /* private fields */ }

A channel abstraction to hide the complexity of partial payloads

Implementations

impl<C: Channel> ChannelBuffer<C>

pub fn new(channel: C) -> Self

pub fn send_msg_chunks<M>(&mut self, msg: &M) -> Result<(), ChannelError>

where M: Fragment,

Enqueues a msg as a sequence payload chunks

pub fn recv_full_msg<M>(&mut self) -> Result<M, ChannelError>

where M: Fragment,

Reads from the channel until a complete message is found

pub fn unwrap(self) -> C

Trait Implementations

impl<C: Channel> From<C> for ChannelBuffer<C>

fn from(channel: C) -> Self

Converts to this type from the input type.