Searched refs:handler (Results 1 – 13 of 13) sorted by relevance
38 handler: Handler, field121 handler, in new()134 if let Some(handler) = &self.handler { in stop_with_error()135 handler.send(Event { in stop_with_error()159 if let Some(handler) = &self.handler { in process()160 handler.send(e)?; in process()178 if let Some(handler) = &self.handler { in close()179 handler.send(e)?; in close()247 if let Some(handler) = &self.handler { in collect()248 handler.send(event)?; in collect()[all …]
85 handler: Handler, field95 if let Some(handler) = &self.handler { in handle()96 handler.send(e)?; in handle()312 if let Some(handler) = ct.handler { in start()313 let _ = handler.send(event); in start()335 if let Some(handler) = ct.handler { in start()336 let _ = handler.send(event); in start()347 if let Some(handler) = ct.handler { in start()434 let has_handler = handler.is_some(); in send()436 if handler.is_some() { in send()[all …]
173 if let Some(handler) = &*on_local_candidate_handler_clone.load() { in gather()174 let mut f = handler.lock().await; in gather()181 if let Some(handler) = &*on_state_change_handler_clone.load() { in gather()182 let mut f = handler.lock().await; in gather()186 if let Some(handler) = &*on_gathering_complete_handler_clone.load() { in gather()187 let mut f = handler.lock().await; in gather()191 if let Some(handler) = &*on_local_candidate_handler_clone.load() { in gather()192 let mut f = handler.lock().await; in gather()279 if let Some(handler) = &*self.on_state_change_handler.load() { in set_state()280 let mut f = handler.lock().await; in set_state()
118 if let Some(handler) = &*on_connection_state_change_handler_clone.load() { in start()119 let mut f = handler.lock().await; in start()135 if let Some(handler) = in start()138 let mut f = handler.lock().await; in start()
258 if let Some(handler) = &*self.on_message_handler.load() { in do_message()259 let mut f = handler.lock().await; in do_message()321 if let Some(handler) = &*on_close_handler2.load() { in read_loop()322 let mut f = handler.lock().await; in read_loop()335 if let Some(handler) = &*on_error_handler2.load() { in read_loop()336 let mut f = handler.lock().await; in read_loop()343 if let Some(handler) = &*on_close_handler2.load() { in read_loop()344 let mut f = handler.lock().await; in read_loop()355 if let Some(handler) = &*on_message_handler.load() { in read_loop()356 let mut f = handler.lock().await; in read_loop()
66 let mut handler = timeout_handler.lock().await; in start() localVariable67 handler.on_timeout(id).await; in start()
238 if let Some(handler) = &*param.on_error_handler.load() { in accept_data_channels()239 let mut f = handler.lock().await; in accept_data_channels()296 if let Some(handler) = &*param.on_data_channel_handler.load() { in accept_data_channels()297 let mut f = handler.lock().await; in accept_data_channels()308 if let Some(handler) = &*param.on_data_channel_opened_handler.load() { in accept_data_channels()309 let mut f = handler.lock().await; in accept_data_channels()
197 pub fn onmute<F>(&self, handler: F) in onmute()203 .store(Some(Arc::new(Mutex::new(Box::new(handler))))); in onmute()206 pub fn onunmute<F>(&self, handler: F) in onunmute()212 .store(Some(Arc::new(Mutex::new(Box::new(handler))))); in onunmute()
299 let mut f = handler.lock().await; in do_signaling_state_change()377 let handler = &*params.on_negotiation_needed_handler.load(); in negotiation_needed_op() localVariable378 if handler.is_none() { in negotiation_needed_op()418 if let Some(handler) = handler { in negotiation_needed_op()419 let mut f = handler.lock().await; in negotiation_needed_op()590 if let Some(handler) = &*on_track_handler.load() { in do_track()591 let mut f = handler.lock().await; in do_track()615 if let Some(handler) = &*handler.load() { in do_ice_connection_state_change()616 let mut f = handler.lock().await; in do_ice_connection_state_change()633 if let Some(handler) = &*handler.load() { in do_peer_connection_state_change()[all …]
139 if let Some(handler) = &*on_data_channel_handler2.load() { in new()140 let mut f = handler.lock().await; in new()
1079 if let Some(handler) = &*ai.on_connection_state_change_hdlr.load() { in start_on_connection_state_change_routine()1080 let mut f = handler.lock().await; in start_on_connection_state_change_routine()1085 if let Some(handler) = &*ai.on_candidate_hdlr.load() { in start_on_connection_state_change_routine()1086 let mut f = handler.lock().await; in start_on_connection_state_change_routine()1095 if let Some(handler) = &*ai.on_candidate_hdlr.load() { in start_on_connection_state_change_routine()1096 let mut f = handler.lock().await; in start_on_connection_state_change_routine()1101 if let Some(handler) = &*ai.on_connection_state_change_hdlr.load() { in start_on_connection_state_change_routine()1102 let mut f = handler.lock().await; in start_on_connection_state_change_routine()
122 if let Some(handler) = &*self.on_state_change_handler.load() { in state_change()123 let mut f = handler.lock().await; in state_change()
463 if let Some(handler) = &*self.on_buffered_amount_low.load() { in on_buffer_released()464 let mut f = handler.lock().await; in on_buffer_released()