Trait PacketDecoder 

pub trait PacketDecoder {
    type Error: Error + Send + Sync + 'static;

    // Required method
    fn decode(
        &self,
        sender: PeerId,
        data: Bytes,
    ) -> Result<IncomingPacket, IncomingPacketError<Self::Error>>;
}

Trait defining decoder HOPR packets.

This operation is done directly by the packet processing pipeline after the underlying p2p transport hands over incoming data packets.

Required Associated Types

type Error: Error + Send + Sync + 'static

Required Methods

fn decode( &self, sender: PeerId, data: Bytes, ) -> Result<IncomingPacket, IncomingPacketError<Self::Error>>

Decodes the data received from the given sender returns the corresponding IncomingPacket if the decoding into a HOPR packet was successful.

Implementations on Foreign Types

impl<'a, T: 'a + PacketDecoder + ?Sized> PacketDecoder for &'a T

type Error = <T as PacketDecoder>::Error

fn decode( &self, sender: PeerId, data: Bytes, ) -> Result<IncomingPacket, IncomingPacketError<Self::Error>>

impl<T: PacketDecoder + ?Sized> PacketDecoder for Box<T>

type Error = <T as PacketDecoder>::Error

fn decode( &self, sender: PeerId, data: Bytes, ) -> Result<IncomingPacket, IncomingPacketError<Self::Error>>

impl<T: PacketDecoder + ?Sized> PacketDecoder for Arc<T>

type Error = <T as PacketDecoder>::Error

fn decode( &self, sender: PeerId, data: Bytes, ) -> Result<IncomingPacket, IncomingPacketError<Self::Error>>

Implementors

impl<Chain, S, T> PacketDecoder for HoprDecoder<Chain, S, T>

where Chain: ChainReadChannelOperations + ChainKeyOperations + ChainReadTicketOperations + ChainValues + Send + Sync, S: SurbStore + Send + Sync + 'static, T: TicketFactory + Send + Sync,

type Error = HoprProtocolError