Struct zenoh_protocol::io::ZBufReader

pub struct ZBufReader<'a> { /* private fields */ }

Implementations

impl<'a> ZBufReader<'a>

pub fn reset(&mut self)

pub fn read_into_zbuf(&mut self, dest: &mut ZBuf, len: usize) -> bool

pub fn read_zslice(&mut self, len: usize) -> Option<ZSlice>

pub fn get_pos(&self) -> ZBufPos

pub fn set_pos(&mut self, pos: ZBufPos)

Methods from Deref<Target = ZBuf>

pub fn get_zslice(&self, index: usize) -> Option<&ZSlice>

pub fn zslices_num(&self) -> usize

Trait Implementations

impl<'a> Clone for ZBufReader<'a>

fn clone(&self) -> ZBufReader<'a>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a> Debug for ZBufReader<'a>

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

Formats the value using the given formatter.

impl Deref for ZBufReader<'_>

type Target = ZBuf

The resulting type after dereferencing.

fn deref(&self) -> &<ZBufReader<'_> as Deref>::Target

Dereferences the value.

impl MessageReader for ZBufReader<'_>

fn read_deco_attachment(&mut self, header: u8) -> Option<Attachment>

fn read_deco_priority(&mut self, header: u8) -> Option<Priority>

fn read_transport_message(&mut self) -> Option<TransportMessage>

fn read_frame(&mut self, header: u8, priority: Priority) -> Option<TransportBody>

fn read_scout(&mut self, header: u8) -> Option<TransportBody>

fn read_hello(&mut self, header: u8) -> Option<TransportBody>

fn read_init_syn(&mut self, header: u8) -> Option<TransportBody>

fn read_init_ack(&mut self, header: u8) -> Option<TransportBody>

fn read_open_syn(&mut self, header: u8) -> Option<TransportBody>

fn read_open_ack(&mut self, header: u8) -> Option<TransportBody>

fn read_join(&mut self, header: u8) -> Option<TransportBody>

fn read_close(&mut self, header: u8) -> Option<TransportBody>

fn read_sync(&mut self, header: u8) -> Option<TransportBody>

fn read_ack_nack(&mut self, header: u8) -> Option<TransportBody>

fn read_keep_alive(&mut self, header: u8) -> Option<TransportBody>

fn read_ping(&mut self, _header: u8) -> Option<TransportBody>

fn read_pong(&mut self, _header: u8) -> Option<TransportBody>

fn read_deco_routing_context(&mut self, _header: u8) -> Option<RoutingContext>

fn read_deco_reply_context(&mut self, header: u8) -> Option<ReplyContext>

fn read_zenoh_message(
    &mut self,
    reliability: Reliability
) -> Option<ZenohMessage>

fn read_data(
    &mut self,
    header: u8,
    reply_context: Option<ReplyContext>
) -> Option<ZenohBody>

fn read_key_expr(&mut self, has_suffix: bool) -> Option<WireExpr<'static>>

fn read_data_info(&mut self) -> Option<DataInfo>

fn read_queryable_info(&mut self) -> Option<QueryableInfo>

fn read_unit(
    &mut self,
    header: u8,
    reply_context: Option<ReplyContext>
) -> Option<ZenohBody>

fn read_pull(&mut self, header: u8) -> Option<ZenohBody>

fn read_declare(&mut self, _header: u8) -> Option<ZenohBody>

fn read_declarations(&mut self) -> Option<Vec<Declaration>>

fn read_declaration(&mut self) -> Option<Declaration>

fn read_query(&mut self, header: u8) -> Option<ZenohBody>

fn read_link_state_list(&mut self, _header: u8) -> Option<ZenohBody>

fn read_link_state(&mut self) -> Option<LinkState>

fn read_submode(&mut self) -> Option<SubMode>

fn read_query_target(&mut self) -> Option<QueryTarget>

fn read_consolidation_mode(mode: ZInt) -> Option<ConsolidationMode>

fn read_consolidation(&mut self) -> Option<ConsolidationMode>

impl<'a> Read for ZBufReader<'a>

fn read(&mut self, buf: &mut [u8]) -> Result<usize, Error>

Pull some bytes from this source into the specified buffer, returning how many bytes were read.

fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), Error>

Read the exact number of bytes required to fill buf.

fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> Result<usize, Error>

Like read, except that it reads into a slice of buffers.

fn is_read_vectored(&self) -> bool

🔬This is a nightly-only experimental API. (can_vector)

Determines if this Reader has an efficient read_vectored implementation.

fn read_to_end(&mut self, buf: &mut Vec<u8, Global>) -> Result<usize, Error>

Read all bytes until EOF in this source, placing them into buf.

fn read_to_string(&mut self, buf: &mut String) -> Result<usize, Error>

Read all bytes until EOF in this source, appending them to buf.

fn read_buf(&mut self, buf: BorrowedCursor<'_>) -> Result<(), Error>

🔬This is a nightly-only experimental API. (read_buf)

Pull some bytes from this source into the specified buffer.

fn read_buf_exact(&mut self, cursor: BorrowedCursor<'_>) -> Result<(), Error>

🔬This is a nightly-only experimental API. (read_buf)

Read the exact number of bytes required to fill cursor.

fn by_ref(&mut self) -> &mut Selfwhere
    Self: Sized,

Creates a “by reference” adaptor for this instance of Read.

fn bytes(self) -> Bytes<Self>where
    Self: Sized,

Transforms this Read instance to an Iterator over its bytes.

fn chain<R>(self, next: R) -> Chain<Self, R>where
    R: Read,
    Self: Sized,

Creates an adapter which will chain this stream with another.

fn take(self, limit: u64) -> Take<Self>where
    Self: Sized,

Creates an adapter which will read at most limit bytes from it.

impl<'a> Reader for ZBufReader<'a>

fn read(&mut self, into: &mut [u8]) -> usize

fn read_exact(&mut self, into: &mut [u8]) -> bool

fn read_byte(&mut self) -> Option<u8>

fn remaining(&self) -> usize

fn can_read(&self) -> bool

impl ZBufCodec for ZBufReader<'_>

fn read_zint(&mut self) -> Option<ZInt>

fn read_zint_as_u64(&mut self) -> Option<u64>

fn read_zint_as_usize(&mut self) -> Option<usize>

fn read_bytes_array(&mut self) -> Option<Vec<u8>>

fn read_string(&mut self) -> Option<String>

fn read_zid(&mut self) -> Option<ZenohId>

fn read_locator(&mut self) -> Option<Locator>

fn read_locators(&mut self) -> Option<Vec<Locator>>

fn read_zslice_array(&mut self) -> Option<ZSlice>

fn read_zbuf_flat(&mut self) -> Option<ZBuf>

fn read_zbuf(&mut self) -> Option<ZBuf>

fn read_properties(&mut self) -> Option<Vec<Property>>

fn read_property(&mut self) -> Option<Property>

fn read_timestamp(&mut self) -> Option<Timestamp>