135     settings: ClientSettings,  field
149         self.settings.rto = rto;  in with_rto()
155         self.settings.rto_rate = d;  in with_timeout_rate()
161         self.settings.buffer_size = buffer_size;  in with_buffer_size()
168         self.settings.collector = Some(coll);  in with_collector()
174         self.settings.c = Some(conn);  in with_conn()
183         self.settings.max_attempts = 0;  in with_no_retransmit()
184         if self.settings.rto == Duration::from_secs(0) {  in with_no_retransmit()
185             self.settings.rto = DEFAULT_MAX_ATTEMPTS * DEFAULT_RTO;  in with_no_retransmit()
192             settings: ClientSettings::default(),  in new()
197         if self.settings.c.is_none() {  in build()
202             settings: self.settings,  in build()
214     settings: ClientSettings,  field
250         if self.settings.closed {  in insert()
265         if self.settings.closed {  in remove()
361         if self.settings.closed {  in close()
365         self.settings.closed = true;  in close()
367         if let Some(collector) = &mut self.settings.collector {  in close()
370         self.settings.collector.take();  in close()
378         if let Some(c) = self.settings.c.take() {  in close()
387         let (client_agent_tx, client_agent_rx) = mpsc::channel(self.settings.buffer_size);  in run()
397         let conn = if let Some(conn) = &self.settings.c {  in run()
404             self.settings.c.clone(),  in run()
408             self.settings.max_attempts,  in run()
414         if self.settings.collector.is_none() {  in run()
415             self.settings.collector = Some(Box::<TickerCollector>::default());  in run()
417         if let Some(collector) = &mut self.settings.collector {  in run()
418             collector.start(self.settings.rto_rate, Arc::clone(&client_agent_tx))?;  in run()
430         if self.settings.closed {  in send()
443                 rto: self.settings.rto,  in send()
456         if let Some(c) = &self.settings.c {  in send()