Trait FilterExt 

pub trait FilterExt<Incoming, Outgoing, Error>:
    Transport<Incoming, Outgoing, Error>
    + Sized
    + Unpin
where
    Error: Error,
{
    // Provided methods
    fn filter_outgoing<Filter>(
        self,
        filter: Filter,
    ) -> Filtering<Self, Incoming, Outgoing, fn(&Incoming) -> bool, Filter, Error>
       where Filter: Filter<Outgoing> { ... }
    fn filter_incoming<Filter>(
        self,
        filter: Filter,
    ) -> Filtering<Self, Incoming, Outgoing, Filter, fn(&Outgoing) -> bool, Error>
       where Filter: Filter<Incoming> { ... }
    fn filter_incoming_and_outgoing<IncomingFilter, OutgoingFilter>(
        self,
        incoming_filter: IncomingFilter,
        outgoing_filter: OutgoingFilter,
    ) -> Filtering<Self, Incoming, Outgoing, IncomingFilter, OutgoingFilter, Error>
       where IncomingFilter: Filter<Incoming>,
             OutgoingFilter: Filter<Outgoing> { ... }
}

Trait for filtering incoming and/or outgoing messages.

Provided Methods

fn filter_outgoing<Filter>( self, filter: Filter, ) -> Filtering<Self, Incoming, Outgoing, fn(&Incoming) -> bool, Filter, Error>

where Filter: Filter<Outgoing>,

Filter outgoing massages.

fn filter_incoming<Filter>( self, filter: Filter, ) -> Filtering<Self, Incoming, Outgoing, Filter, fn(&Outgoing) -> bool, Error>

where Filter: Filter<Incoming>,

Filter incoming messages.

fn filter_incoming_and_outgoing<IncomingFilter, OutgoingFilter>( self, incoming_filter: IncomingFilter, outgoing_filter: OutgoingFilter, ) -> Filtering<Self, Incoming, Outgoing, IncomingFilter, OutgoingFilter, Error>

where IncomingFilter: Filter<Incoming>, OutgoingFilter: Filter<Outgoing>,

Filter incoming and outgoing massages.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<T, Incoming, Outgoing, Error> FilterExt<Incoming, Outgoing, Error> for T

where T: Transport<Incoming, Outgoing, Error> + Unpin, Error: Error,