Enum MessageFilter 

pub enum MessageFilter {
    All,
    MessageType(HashSet<MessageType>),
    FromConnections(HashSet<ConnectionId>),
    ExcludeConnections(HashSet<ConnectionId>),
    Custom(Box<dyn FilterPredicate>),
}

Message filter

Variants

All

Accept all messages

MessageType(HashSet<MessageType>)

Accept messages of specific types

FromConnections(HashSet<ConnectionId>)

Accept messages from specific connections

ExcludeConnections(HashSet<ConnectionId>)

Reject messages from specific connections

Custom(Box<dyn FilterPredicate>)

Custom filter predicate

Implementations

impl MessageFilter

pub fn all() -> Self

Create an “accept all” filter

pub fn message_types(types: Vec<MessageType>) -> Self

Create a filter for specific message types

pub fn from_connections(connections: Vec<ConnectionId>) -> Self

Create a filter for specific connections

pub fn exclude_connections(connections: Vec<ConnectionId>) -> Self

Create a filter to exclude specific connections

pub fn should_deliver( &self, message: &Message, connection_id: &ConnectionId, ) -> bool

Check if a message should be delivered