17 use crate::arbiter::Arbiter;
41     arbiter: Option<Arc<Arbiter>>,  field
153     pub(crate) fn arbiter(&self) -> Option<Arc<Arbiter>> {  in arbiter()  method
155         state.arbiter.clone()  in arbiter()
244                     state.arbiter = Some(Arc::new(Arbiter::new(  in in_evt()
249                     Service::reset(Arc::downgrade(state.arbiter.as_ref().unwrap()));  in in_evt()
326                     let arbiter = state.arbiter.as_ref().unwrap();  in in_evt()  localVariable
327                     arbiter.add_connection(e.connection_handle);  in in_evt()
334                     let arbiter = state.arbiter.as_ref().unwrap();  in in_evt()  localVariable
335                     arbiter.remove_connection(e.connection_handle);  in in_evt()
351                         let arbiter = state.arbiter.as_ref().unwrap();  in in_evt()  localVariable
352                         arbiter.add_connection(*h);  in in_evt()
363                     let arbiter = state.arbiter.as_ref().unwrap();  in in_evt()  localVariable
364                     arbiter.remove_connection(h);  in in_evt()
370                 let Some(arbiter) = state.arbiter.as_ref() else {  in in_evt()
383                         arbiter.set_completed(handle, item.num_completed_packets.into());  in in_evt()
415         let arbiter = state.arbiter.as_ref().unwrap();  in out_iso()  localVariable
416         arbiter.push_incoming(&IsoData::from_bytes(data).unwrap());  in out_iso()