83     Ok(Connection::new(info, tag_socket, config.take().await.deref_mut(), session, cause).await?)  in build_connection()
98             build_connection(&info, &tag_socket, &mut config, None, Cause::Probe).await?;  in new()
107         while let Some(cmd) = self.command_rx.recv().await {  in drive()
110                     if let Err(e) = self.probe(duration).await {  in drive()
115                     if let Err(e) = self.send_query(query).await {  in drive()
136             .await?;  in probe()
141             (self.validation)(&self.info, true).await;  in probe()
144         self.force_probe(probe_timeout).await  in probe()
153             match self.connection.query(dns_request, expiry).await {  in force_probe()
156                     if let Some(_stream) = rsp.await {  in force_probe()
165         match timeout(probe_timeout, request).await {  in force_probe()
176         (self.validation)(&self.info, valid).await;  in force_probe()
188         if !self.connection.wait_for_live().await {  in send_query()
199             .await?;  in send_query()
202         let stream_fut = self.connection.query(request, Some(query.expiry)).await?;  in send_query()
204             let stream = match stream_fut.await {  in send_query()