Trait Decoder

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

Required Methods§

Source

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

Provided Methods§

Source

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

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types§

Source§

impl Decoder for Option<String>

Source§

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

Source§

impl Decoder for i8

Source§

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

Source§

impl Decoder for i32

Source§

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

Source§

impl Decoder for i64

Source§

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

Source§

impl Decoder for u8

Source§

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

Source§

impl Decoder for u16

Source§

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

Source§

impl Decoder for u32

Source§

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

Source§

impl Decoder for u64

Source§

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

Source§

impl Decoder for Vec<u8>

Source§

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

Source§

impl Decoder for Vec<u16>

Source§

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

Source§

impl Decoder for Vec<u32>

Source§

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

Source§

impl Decoder for Vec<u64>

Source§

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

Source§

impl Decoder for Vec<ExchangeCommandVersion>

Source§

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

Source§

impl Decoder for Vec<PublishedMessage>

Source§

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

Source§

impl Decoder for Vec<PublishingError>

Source§

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

Source§

impl Decoder for Vec<String>

Source§

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

Source§

impl Decoder for HashMap<String, String>

Source§

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

Implementors§

Source§

impl Decoder for OffsetSpecification

Source§

impl Decoder for ResponseCode

Source§

impl Decoder for CloseRequest

Source§

impl Decoder for CloseResponse

Source§

impl Decoder for ConsumerUpdateCommand

Source§

impl Decoder for ConsumerUpdateRequestCommand

Source§

impl Decoder for CreateStreamCommand

Source§

impl Decoder for CreateSuperStreamCommand

Source§

impl Decoder for CreditCommand

Source§

impl Decoder for CreditResponse

Source§

impl Decoder for DeclarePublisherCommand

Source§

impl Decoder for Delete

Source§

impl Decoder for DeletePublisherCommand

Source§

impl Decoder for DeleteSuperStreamCommand

Source§

impl Decoder for DeliverCommand

Source§

impl Decoder for ExchangeCommandVersion

Source§

impl Decoder for ExchangeCommandVersionsRequest

Source§

impl Decoder for ExchangeCommandVersionsResponse

Source§

impl Decoder for GenericResponse

Source§

impl Decoder for HeartBeatCommand

Source§

impl Decoder for HeartbeatResponse

Source§

impl Decoder for Broker

Source§

impl Decoder for MetadataCommand

Source§

impl Decoder for MetadataResponse

Source§

impl Decoder for StreamMetadata

Source§

impl Decoder for MetadataUpdateCommand

Source§

impl Decoder for OpenCommand

Source§

impl Decoder for OpenResponse

Source§

impl Decoder for PeerPropertiesCommand

Source§

impl Decoder for PeerPropertiesResponse

Source§

impl Decoder for PublishCommand

Source§

impl Decoder for PublishConfirm

Source§

impl Decoder for PublishErrorResponse

Source§

impl Decoder for QueryOffsetRequest

Source§

impl Decoder for QueryOffsetResponse

Source§

impl Decoder for QueryPublisherRequest

Source§

impl Decoder for QueryPublisherResponse

Source§

impl Decoder for SaslAuthenticateCommand

Source§

impl Decoder for SaslHandshakeCommand

Source§

impl Decoder for SaslHandshakeResponse

Source§

impl Decoder for StoreOffset

Source§

impl Decoder for SubscribeCommand

Source§

impl Decoder for SuperStreamPartitionsRequest

Source§

impl Decoder for SuperStreamPartitionsResponse

Source§

impl Decoder for SuperStreamRouteRequest

Source§

impl Decoder for SuperStreamRouteResponse

Source§

impl Decoder for TunesCommand

Source§

impl Decoder for UnSubscribeCommand

Source§

impl Decoder for Message

Source§

impl Decoder for Request

Source§

impl Decoder for Response

Source§

impl Decoder for Header

Source§

impl Decoder for PublishedMessage

Source§

impl Decoder for PublishingError