Struct ChannelBuffer

pub struct ChannelBuffer<const N: usize> { /* private fields */ }

The main async channel buffer.

Implementations

impl<const N: usize> ChannelBuffer<N>

pub fn new(receiver: Receiver<Bytes<N>>) -> Self

Creates a new ChannelBuffer by wrapping a mpsc channel.

Arguments

• receiver: the channel to wrap.

returns: ChannelBuffer<{ N }>

pub fn close(self)

Closes this ChannelBuffer.

Trait Implementations

impl<const N: usize> AsyncRead for ChannelBuffer<N>

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.