Trait rabbitmq_stream_protocol::codec::Decoder

pub trait Decoder
where
    Self: Sized,
{
    // Required method
    fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>;
}

Required Methods

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl Decoder for Option<String>

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for i8

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for i32

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for i64

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for u8

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for u16

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for u32

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for u64

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for Vec<u8>

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for Vec<u16>

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for Vec<u32>

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for Vec<u64>

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for Vec<PublishedMessage>

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for Vec<PublishingError>

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for Vec<String>

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

impl Decoder for HashMap<String, String>

fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError>

Implementors

impl Decoder for OffsetSpecification

impl Decoder for ResponseCode

impl Decoder for CloseRequest

impl Decoder for CloseResponse

impl Decoder for CreateStreamCommand

impl Decoder for CreditCommand

impl Decoder for CreditResponse

impl Decoder for DeclarePublisherCommand

impl Decoder for Delete

impl Decoder for DeletePublisherCommand

impl Decoder for DeliverCommand

impl Decoder for GenericResponse

impl Decoder for HeartBeatCommand

impl Decoder for HeartbeatResponse

impl Decoder for Broker

impl Decoder for MetadataCommand

impl Decoder for MetadataResponse

impl Decoder for StreamMetadata

impl Decoder for MetadataUpdateCommand

impl Decoder for OpenCommand

impl Decoder for OpenResponse

impl Decoder for PeerPropertiesCommand

impl Decoder for PeerPropertiesResponse

impl Decoder for PublishCommand

impl Decoder for PublishConfirm

impl Decoder for PublishErrorResponse

impl Decoder for QueryOffsetRequest

impl Decoder for QueryOffsetResponse

impl Decoder for QueryPublisherRequest

impl Decoder for QueryPublisherResponse

impl Decoder for SaslAuthenticateCommand

impl Decoder for SaslHandshakeCommand

impl Decoder for SaslHandshakeResponse

impl Decoder for StoreOffset

impl Decoder for SubscribeCommand

impl Decoder for TunesCommand

impl Decoder for UnSubscribeCommand

impl Decoder for Message

impl Decoder for Request

impl Decoder for Response

impl Decoder for Header

impl Decoder for PublishedMessage

impl Decoder for PublishingError