Searched refs:on_message_handler (Results 1 – 1 of 1) sorted by relevance
76 pub(crate) on_message_handler: Arc<ArcSwapOption<Mutex<OnMessageHdlrFn>>>, field254 self.on_message_handler.store(Some(Arc::new(Mutex::new(f)))); in on_message()258 if let Some(handler) = &*self.on_message_handler.load() { in do_message()275 let on_message_handler = Arc::clone(&self.on_message_handler); in handle_open() localVariable284 on_message_handler, in handle_open()303 on_message_handler: Arc<ArcSwapOption<Mutex<OnMessageHdlrFn>>>, in read_loop()355 if let Some(handler) = &*on_message_handler.load() { in read_loop()