(self: Arc<Self>)
| 150 | } |
| 151 | |
| 152 | fn ensure_started(self: Arc<Self>) { |
| 153 | if self.running.swap(true, Ordering::AcqRel) { |
| 154 | return; |
| 155 | } |
| 156 | tokio::spawn(async move { |
| 157 | self.run().await; |
| 158 | }); |
| 159 | } |
| 160 | |
| 161 | async fn discovery(&self, http_origin: Option<&str>) -> WebKitTargetDiscovery { |
| 162 | let state = self.state.read().await.clone(); |