Struct vortex_ipc::messages::MessageDecoder

pub struct MessageDecoder { /* private fields */ }

A stateful reader for decoding IPC messages from an arbitrary stream of bytes.

NOTE(ngates): we should design some trait that the Decoder can take that doesn’t require unique ownership of the underlying bytes. The decoder needs to split out bytes, and advance a cursor, but it doesn’t need to mutate any bytes. So in theory, we should be able to do this zero-copy over a shared buffer of bytes, instead of requiring a BytesMut.

Implementations

impl MessageDecoder

pub fn read_next(&mut self, bytes: &mut BytesMut) -> VortexResult<PollRead>

Attempt to read the next message from the bytes object.

If the message is incomplete, the function will return NeedMore with the total number of bytes needed to make progress. The next call to read_next should provide at least this number of bytes otherwise it will be given the same NeedMore response.

Trait Implementations

impl Default for MessageDecoder

fn default() -> Self

Returns the “default value” for a type.