Struct Data

pub struct Data<T>(pub T);

An Extractor that returns the deserialized data without checking errors. If a deserialization error occurs, the handler won’t be called and an error log will be printed if the tracing feature is enabled.

Deserializing to a generic type (e.g. Data<serde_json::Value>).

Deserialization to a generic type is possible (note that it will be less performant/memory efficient). However if you have binary data in you message. It is recommended to use rmpv::Value rather than serde_json::Value. This is because rmpv::Value has a binary data variant contrary to serde_json::Value. If you still use serde_json::Value with binary data, it will be converted to a sequence of numbers which is less efficient than a binary blob.

Alternatively if your binary fields are at the top level of your object you can deserialize to a type with a dynamic type in it: (serde_json::Value, Bytes, Bytes) or

struct MyData {
    data: serde_json::Value,
    binary1: bytes::Bytes,
    binary2: bytes::Bytes,
}

Tuple Fields

0: T

Trait Implementations

impl<T> Deref for Data<T>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T> DerefMut for Data<T>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<T, A> FromConnectParts<A> for Data<T>

where T: DeserializeOwned, A: Adapter,

type Error = ParserError

The error type returned by the extractor

fn from_connect_parts( s: &Arc<Socket<A>>, auth: &Option<Value>, ) -> Result<Self, Self::Error>

Extract the arguments from the connect event. If it fails, the handler is not called

impl<T, A> FromMessageParts<A> for Data<T>

where T: DeserializeOwned, A: Adapter,

type Error = ParserError

The error type returned by the extractor

fn from_message_parts( s: &Arc<Socket<A>>, v: &mut Value, _: &Option<i64>, ) -> Result<Self, Self::Error>

Extract the arguments from the message event. If it fails, the handler is not called.