Trait pulsar::DeserializeMessage

pub trait DeserializeMessage {
    type Output: Sized;

    // Required method
    fn deserialize_message(payload: &Payload) -> Self::Output;
}

Helper trait for consumer deserialization

Required Associated Types

type Output: Sized

type produced from the message

Required Methods

fn deserialize_message(payload: &Payload) -> Self::Output

deserialize method that will be called by the consumer

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl DeserializeMessage for String

type Output = Result<String, FromUtf8Error>

fn deserialize_message(payload: &Payload) -> Self::Output

impl DeserializeMessage for Vec<u8>

type Output = Vec<u8>

fn deserialize_message(payload: &Payload) -> Self::Output

Implementors