Enum WebSocketReadMode 

pub enum WebSocketReadMode {
    Latest,
    All,
    FromIndex(u64),
}

Read mode for WebSocket buffer.

Determines how messages are retrieved from the buffer.

Variants

Latest

Return only the most recent message (default, backward compatible).

All

Return all accumulated messages.

FromIndex(u64)

Return messages newer than the given index.

Note: Index wraparound at u64::MAX is not handled. See DataBuffer documentation for limitations. At 1 million messages per second, wraparound would take ~584,000 years.

Trait Implementations

impl BorshDeserialize for WebSocketReadMode

fn deserialize_reader<__R: Read>(reader: &mut __R) -> Result<Self, Error>

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

Deserializes this instance from a given slice of bytes. Updates the buffer to point at the remaining bytes.

fn try_from_slice(v: &[u8]) -> Result<Self, Error>

Deserialize this instance from a slice of bytes.

fn try_from_reader<R>(reader: &mut R) -> Result<Self, Error>

where R: Read,

impl BorshSerialize for WebSocketReadMode

fn serialize<__W: Write>(&self, writer: &mut __W) -> Result<(), Error>

impl Clone for WebSocketReadMode

fn clone(&self) -> WebSocketReadMode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WebSocketReadMode

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

Formats the value using the given formatter.

impl Default for WebSocketReadMode

fn default() -> WebSocketReadMode

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for WebSocketReadMode

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl EnumExt for WebSocketReadMode

fn deserialize_variant<__R: Read>( reader: &mut __R, variant_tag: u8, ) -> Result<Self, Error>

Deserialises given variant of an enum from the reader.

impl Eq for WebSocketReadMode

impl PartialEq for WebSocketReadMode

fn eq(&self, other: &WebSocketReadMode) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for WebSocketReadMode

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for WebSocketReadMode