Struct TrafficProcessorHolder 

pub struct TrafficProcessorHolder<C>
where
    C: Encoder<Bytes> + Decoder<Item = BytesMut, Error = Error> + Clone + Send + 'static,
{ /* private fields */ }

Implementations

impl<C> TrafficProcessorHolder<C>

where C: Encoder<Bytes> + Decoder<Item = BytesMut, Error = Error> + Clone + Send + 'static,

pub fn new() -> Self

pub fn register_processor( &mut self, processor: Box<dyn TrafficProcess<Codec = C>>, )

pub async fn initial_connect(&mut self, source: &mut Transport) -> bool

pub async fn initial_framed_connect( &mut self, source: &mut Framed<Transport, C>, ) -> bool

pub async fn post_process_traffic(&mut self, data: Vec<u8>) -> Vec<u8>

pub async fn pre_process_traffic(&mut self, data: BytesMut) -> BytesMut

Trait Implementations

impl<C> Clone for TrafficProcessorHolder<C>

where C: Encoder<Bytes> + Decoder<Item = BytesMut, Error = Error> + Clone + Send + 'static,

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.