Struct ListenerRegistry 

pub struct ListenerRegistry { /* private fields */ }

Implementations

impl ListenerRegistry

pub fn insert( &mut self, key: ListenerKey, listener: Listener, ) -> Option<Listener>

pub fn remove(&mut self, key: &ListenerKey) -> Option<Listener>

pub fn get(&self, key: &ListenerKey) -> Option<&Listener>

pub async fn shutdown(self) -> Result<()>

Stop and drain every Listener.

pub async fn apply<H: Handler>( &mut self, servers: HashMap<ListenerKey, H>, ) -> Result<Vec<Arc<H>>>

Bind new Listeners before changing handlers; return replaced states for draining.

Trait Implementations

impl Default for ListenerRegistry

fn default() -> Self

Returns the “default value” for a type.