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 fn new(stream: S) -> Self

pub fn stream(&self) -> &S

pub fn unwrap(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<(u32, Command), StreamError>

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