Struct loco_protocol::command::codec::CommandCodec

pub struct CommandCodec<S> { /* fields omitted */ }

Provide Command read / write operation to stream

Implementations

impl<S> CommandCodec<S>

pub const fn new(stream: S) -> Self

pub const fn stream(&self) -> &S

pub fn stream_mut(&mut self) -> &mut S

pub fn into_inner(self) -> S

impl<S: Write> CommandCodec<S>

pub fn write(&mut self, command: &Command) -> Result<usize, StreamError>

Write command to stream

impl<S: Read> CommandCodec<S>

pub fn read(&mut self) -> Result<(usize, Command), StreamError>

Read one command from stream. Returns tuple with read size and Command.

impl<S: AsyncRead + Unpin> CommandCodec<S>

pub async fn read_async(&mut self) -> Result<(usize, Command), StreamError>

Read one command from stream async. Returns tuple with read size and Command.

impl<S: AsyncWrite + Unpin> CommandCodec<S>

pub async fn write_async(
    &mut self,
    command: &Command
) -> Result<usize, StreamError>

Write command to stream async

Trait Implementations

impl<S: Debug> Debug for CommandCodec<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.